public class ClientBusProxyImpl extends Object implements MessageBus
Constructor and Description |
---|
ClientBusProxyImpl(MessageBus serverBus) |
Modifier and Type | Method and Description |
---|---|
void |
addGlobalListener(MessageListener listener) |
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 |
attachMonitor(BusMonitor monitor)
Attach a monitor to the bus.
|
void |
conversationWith(Message message,
MessageCallback callback) |
boolean |
isSubscribed(String subject)
Returns true if there the specified subject has one or more listeners registered.
|
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).
|
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 ClientBusProxyImpl(MessageBus serverBus)
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 void conversationWith(Message message, MessageCallback callback)
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 addGlobalListener(MessageListener listener)
public void addSubscribeListener(SubscribeListener listener)
MessageBus
addSubscribeListener
in interface MessageBus
public void addUnsubscribeListener(UnsubscribeListener listener)
MessageBus
addUnsubscribeListener
in interface MessageBus
public void attachMonitor(BusMonitor monitor)
MessageBus
attachMonitor
in interface MessageBus
Copyright © 2013-2015 JBoss, a division of Red Hat. All Rights Reserved.