PublishingService<T>
, SubscriptionService<T>
EventBrokerService
, RequestBrokerService
setMessageHandler(handler)
to handle incoming messages asynchronously.@Deprecated public abstract class MessageBrokerService<T> extends BrokerServiceBase<T>
MessageBrokerService<T>
class implements the Publish/Subscribe pattern.
This class has a specific behavior - it performs synchronous wait in AsyncInvoker for incoming events,
so, it requires dedicated invoker to be permanently busy with reading task.
The alternative for broker service functionality without fully occupied invoker is to use
EventReceivingBrokerService and RequestReceivingBrokerService which are
receivers by themselves and can be used as "external receivers" in protocol connections
to handle messages directly without intermediate queues.Modifier and Type | Class | Description |
---|---|---|
protected static class |
MessageBrokerService.LifecycleStage |
Deprecated.
|
Modifier and Type | Field | Description |
---|---|---|
protected java.lang.Object |
lifecycleLock |
Deprecated.
|
protected MessageBrokerService.LifecycleStage |
status |
Deprecated.
|
Modifier | Constructor | Description |
---|---|---|
protected |
MessageBrokerService() |
Deprecated.
Creates an instance of
MessageBrokerService class. |
protected |
MessageBrokerService(AsyncInvoker theInvoker) |
Deprecated.
Creates an instance of
MessageBrokerService class. |
Modifier and Type | Method | Description |
---|---|---|
void |
activate() |
Deprecated.
Activates the service.
|
void |
deactivate() |
Deprecated.
Deactivates the service.
|
void |
dispose() |
Deprecated.
Disposes of the service.
|
protected abstract Receiver |
getGenericReceiver() |
Deprecated.
|
AsyncInvoker |
getInvoker() |
Deprecated.
Gets asynchronous invoker.
|
boolean |
isActive() |
Deprecated.
Checks if the service is active.
|
protected abstract T |
receive() |
Deprecated.
|
void |
setInvoker(AsyncInvoker theInvoker) |
Deprecated.
Sets asynchronous invoker.
|
notify, onNotificationException, onPublish, publish, register, register, switchSubscribersList, unregister, unregister, unregisterAll
protected MessageBrokerService.LifecycleStage status
protected final java.lang.Object lifecycleLock
protected MessageBrokerService()
MessageBrokerService
class.protected MessageBrokerService(AsyncInvoker theInvoker)
MessageBrokerService
class.theInvoker
- Initializes asynchronous invokerpublic AsyncInvoker getInvoker()
public void setInvoker(AsyncInvoker theInvoker)
theInvoker
- asynchronous invokerpublic boolean isActive()
public void activate()
public void deactivate()
public void dispose()
protected abstract T receive() throws java.lang.InterruptedException
java.lang.InterruptedException
protected abstract Receiver getGenericReceiver()
Send comments on this topicTechpubs.webadmin@genesys.com.
Document version: 9.0.006.00
Copyright © 2006–2019 Genesys Telecommunications Laboratories, Inc. All rights reserved.