org.jboss.jms.client.remoting
Class MessageCallbackHandler

java.lang.Object
  org.jboss.jms.client.remoting.MessageCallbackHandler

public class MessageCallbackHandler

extends java.lang.Object

Version:

$Revision: 2684 $ $Id: MessageCallbackHandler.java 2684 2007-05-15 07:31:30Z timfox $

Author:

Ovidiu Feodorov, Tim Fox/a>

Constructor Summary

MessageCallbackHandler(boolean isCC, int ackMode, SessionDelegate sess, ConsumerDelegate cons, int consumerID, java.lang.String queueName, int bufferSize, QueuedExecutor sessionExecutor, int maxDeliveries)

Method Summary

void	addToFrontOfBuffer(MessageProxy proxy)
static void	callOnMessage(SessionDelegate sess, MessageListener listener, int consumerID, java.lang.String queueName, boolean isConnectionConsumer, MessageProxy m, int ackMode, int maxDeliveries, SessionDelegate connectionConsumerSession)
void	cancelBuffer()
void	close(long lastDeliveryId)
int	getConsumerId()
MessageListener	getMessageListener()
void	handleMessage(java.lang.Object message) Handles a message sent from the server.
MessageProxy	receive(long timeout) Method used by the client thread to get a Message, if available.
void	setConsumerId(int consumerId)
void	setMessageListener(MessageListener listener)
void	synchronizeWith(MessageCallbackHandler newHandler) Needed for failover
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageCallbackHandler

public MessageCallbackHandler(boolean isCC,
                              int ackMode,
                              SessionDelegate sess,
                              ConsumerDelegate cons,
                              int consumerID,
                              java.lang.String queueName,
                              int bufferSize,
                              QueuedExecutor sessionExecutor,
                              int maxDeliveries)

Method Detail

callOnMessage

public static void callOnMessage(SessionDelegate sess,
                                 MessageListener listener,
                                 int consumerID,
                                 java.lang.String queueName,
                                 boolean isConnectionConsumer,
                                 MessageProxy m,
                                 int ackMode,
                                 int maxDeliveries,
                                 SessionDelegate connectionConsumerSession)
                          throws JMSException

Throws:

JMSException

handleMessage

public void handleMessage(java.lang.Object message)
                   throws java.lang.Exception

Handles a message sent from the server.

Parameters:

message - The message

Throws:

java.lang.Exception

setMessageListener

public void setMessageListener(MessageListener listener)
                        throws JMSException

Throws:

JMSException

cancelBuffer

public void cancelBuffer()
                  throws JMSException

Throws:

JMSException

close

public void close(long lastDeliveryId)
           throws JMSException

Throws:

JMSException

receive

public MessageProxy receive(long timeout)
                     throws JMSException

Method used by the client thread to get a Message, if available.

Parameters:

timeout - - the timeout value in milliseconds. A zero timeount never expires, and the call blocks indefinitely. A -1 timeout means receiveNoWait(): return the next message or null if one is not immediately available. Returns null if the consumer is concurrently closed.

Throws:

JMSException

getMessageListener

public MessageListener getMessageListener()

toString

public java.lang.String toString()

getConsumerId

public int getConsumerId()

setConsumerId

public void setConsumerId(int consumerId)

addToFrontOfBuffer

public void addToFrontOfBuffer(MessageProxy proxy)
                        throws java.lang.Exception

Throws:

java.lang.Exception

synchronizeWith

public void synchronizeWith(MessageCallbackHandler newHandler)

Needed for failover