Package com.levigo.jadice.web.transport.client.messaging

Class ConversationMessageListener

java.lang.Object

com.levigo.jadice.web.transport.client.messaging.ConversationMessageListener

All Implemented Interfaces:

MessageListener

public final class ConversationMessageListener
extends Object
implements MessageListener

This listener is responsible for handling messages that are sent as part of a conversation, i.e. when the client sends a message and expects one or more direct responses to the sent message. In this case, we need to preserve the context so one callback can handle different message types. Conversations require some more control flow than usual, they need to be ended by the server once it is done processing a message.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ConversationMessageListener.ConversationListener

Method Summary

Modifier and Type	Method	Description
void	consume(Message message)
static ConversationMessageListener	get()
void	registerConversation(int conversationId, ConversationMessageListener.ConversationListener listener)
void	unregisterConversation(int conversationId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

consume

public void consume(Message message)
             throws Exception

Specified by:

consume in interface MessageListener

Throws:

Exception

registerConversation

public void registerConversation(int conversationId,
 ConversationMessageListener.ConversationListener listener)

unregisterConversation

public void unregisterConversation(int conversationId)

get

public static ConversationMessageListener get()