org.jboss.jms.client.delegate
Class ClientConsumerDelegate

java.lang.Object
  org.jboss.jms.client.delegate.DelegateSupport
      org.jboss.jms.client.delegate.ClientConsumerDelegate

All Implemented Interfaces:

Closeable, ConsumerDelegate, ConsumerEndpoint, java.io.Serializable

public class ClientConsumerDelegate

extends DelegateSupport

implements ConsumerDelegate

The client-side Consumer delegate class.

Version:

$Revision: 1571 $ $Id: ClientConsumerDelegate.java 1571 2006-11-17 03:31:19Z ovidiu.feodorov@jboss.com $

Author:

Tim Fox, Ovidiu Feodorov

See Also:

Serialized Form

Field Summary

protected int	bufferSize
protected int	maxDeliveries

Fields inherited from class org.jboss.jms.client.delegate.DelegateSupport

id, state

Constructor Summary

ClientConsumerDelegate()

ClientConsumerDelegate(int objectID, int bufferSize, int maxDeliveries)

Method Summary

void	close() This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
void	closing() This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
protected Client	getClient()
JBossDestination	getDestination() This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
MessageListener	getMessageListener() This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
java.lang.String	getMessageSelector() This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
boolean	getNoLocal() This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
void	init() Add Invoking interceptor and prepare the stack for invocations.
boolean	isClosed() This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
void	more() This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
Message	receive(long timeout) This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
void	setMessageListener(MessageListener listener) This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.
java.lang.String	toString()

Methods inherited from class org.jboss.jms.client.delegate.DelegateSupport

getID, getMetaData, getName, getState, invoke, setState

Methods inherited from class java.lang.Object

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

Field Detail

bufferSize

protected int bufferSize

maxDeliveries

protected int maxDeliveries

Constructor Detail

ClientConsumerDelegate

public ClientConsumerDelegate(int objectID,
                              int bufferSize,
                              int maxDeliveries)

ClientConsumerDelegate

public ClientConsumerDelegate()

Method Detail

more

public void more()

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

more in interface ConsumerEndpoint

close

public void close()
           throws JMSException

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

close in interface Closeable

Throws:

JMSException

closing

public void closing()
             throws JMSException

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

closing in interface Closeable

Throws:

JMSException

isClosed

public boolean isClosed()

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

isClosed in interface Closeable

getMessageListener

public MessageListener getMessageListener()

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

getMessageListener in interface ConsumerDelegate

receive

public Message receive(long timeout)
                throws JMSException

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

receive in interface ConsumerDelegate

Throws:

JMSException

setMessageListener

public void setMessageListener(MessageListener listener)

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

setMessageListener in interface ConsumerDelegate

getNoLocal

public boolean getNoLocal()

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

getNoLocal in interface ConsumerDelegate

getDestination

public JBossDestination getDestination()

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

getDestination in interface ConsumerDelegate

getMessageSelector

public java.lang.String getMessageSelector()

This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint.

Specified by:

getMessageSelector in interface ConsumerDelegate

init

public void init()

Description copied from class: DelegateSupport

Add Invoking interceptor and prepare the stack for invocations.

Overrides:

init in class DelegateSupport

toString

public java.lang.String toString()

getClient

protected Client getClient()

Specified by:

getClient in class DelegateSupport