Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.transport.stomp
Class Subscription  view Subscription download Subscription.java

java.lang.Object
  extended byorg.activemq.transport.stomp.Subscription

class Subscription
extends java.lang.Object


Field Summary
private  int ackMode
           
(package private) static int AUTO_ACK
           
(package private) static int CLIENT_ACK
           
private  short consumer_no
           
private  java.lang.String consumerId
           
private  org.activemq.message.ActiveMQDestination destination
           
private  StompWireFormat format
           
static java.lang.String NO_ID
           
private  java.lang.String subscriptionId
           
 
Constructor Summary
(package private) Subscription(StompWireFormat format, short consumer_no, java.lang.String consumerId, java.lang.String subscriptionId)
           
 
Method Summary
 org.activemq.message.ConsumerInfo close()
           
(package private)  org.activemq.message.ActiveMQDestination getDestination()
           
(package private)  void receive(org.activemq.message.ActiveMQBytesMessage msg, java.io.DataOutput out)
           
(package private)  void receive(org.activemq.message.ActiveMQTextMessage msg, java.io.DataOutput out)
           
 void setAckMode(int clientAck)
           
(package private)  void setDestination(org.activemq.message.ActiveMQDestination actual_dest)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

destination

private org.activemq.message.ActiveMQDestination destination

ackMode

private int ackMode

format

private StompWireFormat format

consumer_no

private short consumer_no

consumerId

private final java.lang.String consumerId

subscriptionId

private final java.lang.String subscriptionId

NO_ID

public static final java.lang.String NO_ID
See Also:
Constant Field Values

AUTO_ACK

static final int AUTO_ACK
See Also:
Constant Field Values

CLIENT_ACK

static final int CLIENT_ACK
See Also:
Constant Field Values
Constructor Detail

Subscription

Subscription(StompWireFormat format,
             short consumer_no,
             java.lang.String consumerId,
             java.lang.String subscriptionId)
Method Detail

setDestination

void setDestination(org.activemq.message.ActiveMQDestination actual_dest)

receive

void receive(org.activemq.message.ActiveMQTextMessage msg,
             java.io.DataOutput out)
       throws java.io.IOException,
              javax.jms.JMSException

receive

void receive(org.activemq.message.ActiveMQBytesMessage msg,
             java.io.DataOutput out)
       throws java.io.IOException,
              javax.jms.JMSException

getDestination

org.activemq.message.ActiveMQDestination getDestination()

setAckMode

public void setAckMode(int clientAck)

close

public org.activemq.message.ConsumerInfo close()