Errai 3.0.1-SNAPSHOT

org.jboss.errai.bus.server
Class ServerMessageBusImpl.RemoteMessageCallback

java.lang.Object
  extended by org.jboss.errai.bus.server.ServerMessageBusImpl.RemoteMessageCallback
All Implemented Interfaces:
MessageCallback
Enclosing class:
ServerMessageBusImpl

public class ServerMessageBusImpl.RemoteMessageCallback
extends Object
implements MessageCallback


Constructor Summary
ServerMessageBusImpl.RemoteMessageCallback(boolean broadcastable, String svc)
           
 
Method Summary
 void addQueue(MessageQueue queue)
           
 void callback(Message message)
          Called by the Message Bus every time it processes a message with the subject this callback is registered for.
 boolean contains(MessageQueue queue)
           
 int getQueueCount()
           
 Collection<MessageQueue> getQueues()
           
 void removeQueue(MessageQueue queue)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ServerMessageBusImpl.RemoteMessageCallback

public ServerMessageBusImpl.RemoteMessageCallback(boolean broadcastable,
                                                  String svc)
Method Detail

callback

public void callback(Message message)
Description copied from interface: MessageCallback
Called by the Message Bus every time it processes a message with the subject this callback is registered for.

Specified by:
callback in interface MessageCallback
Parameters:
message - The message on the bus. Avoid making changes to this object, because it will continue to be reused by the framework and the same Message instance will be passed to other callbacks.

addQueue

public void addQueue(MessageQueue queue)

removeQueue

public void removeQueue(MessageQueue queue)

getQueues

public Collection<MessageQueue> getQueues()

getQueueCount

public int getQueueCount()

contains

public boolean contains(MessageQueue queue)

Errai 3.0.1-SNAPSHOT

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