public class MessageBusProxy extends Object implements ServerMessageBus
Constructor and Description |
---|
MessageBusProxy() |
Modifier and Type | Method and Description |
---|---|
void |
addQueueClosedListener(QueueClosedListener listener)
Register a
QueueClosedListener with the bus. |
void |
addSubscribeListener(SubscribeListener listener)
Registers a subscription listener, which is fired whenever a new subscription is created.
|
void |
addUnsubscribeListener(UnsubscribeListener listener)
Registers an un-subscribe listener, which is fired whenever a subscription is cancelled.
|
void |
associateNewQueue(QueueSession oldSession,
QueueSession newSession) |
void |
attachMonitor(BusMonitor monitor)
Attach a monitor to the bus.
|
void |
closeProxy(ServerMessageBus bus) |
void |
closeQueue(MessageQueue queue)
Closes the specified message queue
|
void |
closeQueue(String sessionId)
Closes the queue associated with the sessionId
|
void |
configure(ErraiServiceConfigurator service)
Configures the bus using the configuration specified
|
Message |
getDeadLetterMessage(String messageId) |
Map<QueueSession,MessageQueue> |
getMessageQueues() |
MessageQueue |
getQueue(QueueSession session)
Gets the queue containing the messages that are waiting to be transmitted
|
MessageQueue |
getQueueBySession(String id) |
Collection<MessageCallback> |
getReceivers(String subject)
Get a collection of all receivers registered for a specificed subject
|
ExecutorService |
getScheduler()
Returns the associated scheduler which keeps track of timed events
|
QueueSession |
getSessionBySessionId(String id) |
boolean |
hasRemoteSubscription(String sessionId,
String subject) |
boolean |
hasRemoteSubscriptions(String subject) |
boolean |
isSubscribed(String subject)
Returns true if there the specified subject has one or more listeners registered.
|
boolean |
removeDeadLetterMessage(String messageId) |
void |
send(Message message)
Transmits a message.
|
void |
send(Message message,
boolean fireListeners)
Transmits a message and may optionally supress message listeners from firing.
|
void |
sendGlobal(Message message)
Transmits the message to all directly-peered buses (global in relation to this bus only).
|
void |
stop()
Stop the MessateBus.
|
Subscription |
subscribe(String subject,
MessageCallback receiver)
Subscribe a listener to the specified subject.
|
Subscription |
subscribeLocal(String subject,
MessageCallback receiver)
Subscribe a listern locally, but do not advertise or make available the service to remote buses.
|
void |
unsubscribeAll(String subject)
Unsubscribe all listeners registered for the specified subject.
|
public void sendGlobal(Message message)
MessageBus
sendGlobal
in interface MessageBus
message
- - The message to be sent.public void send(Message message)
MessageBus
send
in interface MessageBus
public void send(Message message, boolean fireListeners)
MessageBus
send
in interface MessageBus
public Subscription subscribe(String subject, MessageCallback receiver)
MessageBus
subscribe
in interface MessageBus
public Subscription subscribeLocal(String subject, MessageCallback receiver)
MessageBus
subscribeLocal
in interface MessageBus
public void unsubscribeAll(String subject)
MessageBus
unsubscribeAll
in interface MessageBus
public boolean isSubscribed(String subject)
MessageBus
isSubscribed
in interface MessageBus
public void addSubscribeListener(SubscribeListener listener)
MessageBus
addSubscribeListener
in interface MessageBus
public void addUnsubscribeListener(UnsubscribeListener listener)
MessageBus
addUnsubscribeListener
in interface MessageBus
public MessageQueue getQueue(QueueSession session)
ServerMessageBus
getQueue
in interface ServerMessageBus
session
- - the session of the queuepublic void closeQueue(String sessionId)
ServerMessageBus
closeQueue
in interface ServerMessageBus
sessionId
- - the session id of the message queuepublic void closeQueue(MessageQueue queue)
ServerMessageBus
closeQueue
in interface ServerMessageBus
queue
- - the message queue to closepublic ExecutorService getScheduler()
ServerMessageBus
getScheduler
in interface ServerMessageBus
public void addQueueClosedListener(QueueClosedListener listener)
ServerMessageBus
QueueClosedListener
with the bus.addQueueClosedListener
in interface ServerMessageBus
listener
- a instance of the listenerpublic void configure(ErraiServiceConfigurator service)
ServerMessageBus
configure
in interface ServerMessageBus
service
- - the configuration to usepublic Collection<MessageCallback> getReceivers(String subject)
ServerMessageBus
getReceivers
in interface ServerMessageBus
subject
- The subject.public boolean hasRemoteSubscriptions(String subject)
hasRemoteSubscriptions
in interface ServerMessageBus
public boolean hasRemoteSubscription(String sessionId, String subject)
hasRemoteSubscription
in interface ServerMessageBus
public Map<QueueSession,MessageQueue> getMessageQueues()
getMessageQueues
in interface ServerMessageBus
public MessageQueue getQueueBySession(String id)
getQueueBySession
in interface ServerMessageBus
public QueueSession getSessionBySessionId(String id)
getSessionBySessionId
in interface ServerMessageBus
public void associateNewQueue(QueueSession oldSession, QueueSession newSession)
associateNewQueue
in interface ServerMessageBus
public void stop()
ServerMessageBus
stop
in interface ServerMessageBus
public Message getDeadLetterMessage(String messageId)
getDeadLetterMessage
in interface ServerMessageBus
public boolean removeDeadLetterMessage(String messageId)
removeDeadLetterMessage
in interface ServerMessageBus
public void attachMonitor(BusMonitor monitor)
MessageBus
attachMonitor
in interface MessageBus
public void closeProxy(ServerMessageBus bus)
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.