Errai 3.0.1-SNAPSHOT

org.jboss.errai.tools.monitoring
Class ClientBusProxyImpl

java.lang.Object
  extended by org.jboss.errai.tools.monitoring.ClientBusProxyImpl
All Implemented Interfaces:
MessageBus

public class ClientBusProxyImpl
extends Object
implements MessageBus


Constructor Summary
ClientBusProxyImpl(MessageBus serverBus)
           
 
Method Summary
 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.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ClientBusProxyImpl

public ClientBusProxyImpl(MessageBus serverBus)
Method Detail

sendGlobal

public void sendGlobal(Message message)
Description copied from interface: MessageBus
Transmits the message to all directly-peered buses (global in relation to this bus only).

Specified by:
sendGlobal in interface MessageBus
Parameters:
message - - The message to be sent.

send

public void send(Message message)
Description copied from interface: MessageBus
Transmits a message.

Specified by:
send in interface MessageBus

send

public void send(Message message,
                 boolean fireListeners)
Description copied from interface: MessageBus
Transmits a message and may optionally supress message listeners from firing. This is useful if you are modifying a message from within a listener itself, and wish to retransmit the message.

Specified by:
send in interface MessageBus

conversationWith

public void conversationWith(Message message,
                             MessageCallback callback)

subscribe

public Subscription subscribe(String subject,
                              MessageCallback receiver)
Description copied from interface: MessageBus
Subscribe a listener to the specified subject.

Specified by:
subscribe in interface MessageBus

subscribeLocal

public Subscription subscribeLocal(String subject,
                                   MessageCallback receiver)
Description copied from interface: MessageBus
Subscribe a listern locally, but do not advertise or make available the service to remote buses.

Specified by:
subscribeLocal in interface MessageBus

unsubscribeAll

public void unsubscribeAll(String subject)
Description copied from interface: MessageBus
Unsubscribe all listeners registered for the specified subject.

Specified by:
unsubscribeAll in interface MessageBus

isSubscribed

public boolean isSubscribed(String subject)
Description copied from interface: MessageBus
Returns true if there the specified subject has one or more listeners registered.

Specified by:
isSubscribed in interface MessageBus
Returns:

addGlobalListener

public void addGlobalListener(MessageListener listener)

addSubscribeListener

public void addSubscribeListener(SubscribeListener listener)
Description copied from interface: MessageBus
Registers a subscription listener, which is fired whenever a new subscription is created.

Specified by:
addSubscribeListener in interface MessageBus

addUnsubscribeListener

public void addUnsubscribeListener(UnsubscribeListener listener)
Description copied from interface: MessageBus
Registers an un-subscribe listener, which is fired whenever a subscription is cancelled.

Specified by:
addUnsubscribeListener in interface MessageBus

attachMonitor

public void attachMonitor(BusMonitor monitor)
Description copied from interface: MessageBus
Attach a monitor to the bus.

Specified by:
attachMonitor in interface MessageBus

Errai 3.0.1-SNAPSHOT

Copyright © 2013-2014 JBoss, a division of Red Hat. All Rights Reserved.