org.jboss.mq
Class Subscription

java.lang.Object
  org.jboss.mq.Subscription

All Implemented Interfaces:

java.io.Serializable

public class Subscription

extends java.lang.Object

implements java.io.Serializable

This class contains all the data needed to for a the provider to to determine if a message can be routed to a consumer.

See Also:

Serialized Form

subscriptionId

public int subscriptionId

This gets set to a unique value at the SpyConnection.

destination

public SpyDestination (src)  destination

The queue we want to subscribe to.

messageSelector

public java.lang.String messageSelector

The selector which will filter out messages.

destroyDurableSubscription

public boolean destroyDurableSubscription

Should this message destroy the subscription?

noLocal

public boolean noLocal

Topics might not want locally produced messages.

selector

public transient Selector (src)  selector

The message selector

connectionToken

public transient ConnectionToken (src)  connectionToken

The connection token

clientConsumer

public transient java.lang.Object clientConsumer

The client consumer

Subscription

public Subscription()

getSelector

public Selector (src)  getSelector()
                     throws InvalidSelectorException (src) 

Determines the consumer would accept the message.

Returns:

the selector

Throws:

InvalidSelectorException (src) - for an invalid selector

accepts

public boolean accepts(SpyMessage.Header (src)  header)
                throws JMSException (src) 

Determines the consumer would accept the message.

Parameters:

header - the message header

Returns:

true when accepted, false otherwise

Throws:

JMSException (src) - for any error

myClone

public Subscription (src)  myClone()

Clone the subscription

Returns:

the cloned subscription

toString

public java.lang.String toString()