PublishingService<T>
, SubscriptionService<T>
, AsyncInvokerSupport
, InvokerInfo
AsyncBrokerService
, EventReceivingBrokerService
, RequestReceivingBrokerService
setMessageHandler(handler)
to handle incoming messages asynchronously.@Deprecated public abstract class AsyncBrokerServiceBase<T> extends BrokerServiceBase<T> implements AsyncInvokerSupport, InvokerInfo
AsyncBrokerServiceBase
class extends base implementation
of the Publish/Subscribe pattern with asynchronous publishing.Modifier | Constructor | Description |
---|---|---|
protected |
AsyncBrokerServiceBase() |
Deprecated.
|
protected |
AsyncBrokerServiceBase(AsyncInvoker invoker) |
Deprecated.
|
Modifier and Type | Method | Description |
---|---|---|
long |
getInvokesCount() |
Deprecated.
|
long |
getInvokesRejected() |
Deprecated.
|
int |
getQueueMaxSize() |
Deprecated.
|
int |
getQueueSize() |
Deprecated.
|
void |
publish(T obj) |
Deprecated.
Enqueues event for publishing by the invoker.
|
void |
setInvoker(AsyncInvoker invoker) |
Deprecated.
|
notify, onNotificationException, onPublish, register, register, switchSubscribersList, unregister, unregister, unregisterAll
protected AsyncBrokerServiceBase()
protected AsyncBrokerServiceBase(AsyncInvoker invoker)
public void setInvoker(AsyncInvoker invoker)
setInvoker
in interface AsyncInvokerSupport
public int getQueueMaxSize()
getQueueMaxSize
in interface InvokerInfo
public int getQueueSize()
getQueueSize
in interface InvokerInfo
public long getInvokesCount()
getInvokesCount
in interface InvokerInfo
public long getInvokesRejected()
getInvokesRejected
in interface InvokerInfo
public void publish(T obj)
publish
in interface PublishingService<T>
publish
in class BrokerServiceBase<T>
obj
- Object that is used for event processingjava.lang.IllegalStateException
- if no AsyncInvoker initializedsetInvoker(AsyncInvoker)
Send comments on this topicTechpubs.webadmin@genesys.com.
Document version: 9.0.006.00
Copyright © 2006–2019 Genesys Telecommunications Laboratories, Inc. All rights reserved.