|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.jms.client.delegate.DelegateSupport
org.jboss.jms.client.delegate.ClientSessionDelegate
public class ClientSessionDelegate
The client-side Session delegate class.
Field Summary |
---|
Fields inherited from class org.jboss.jms.client.delegate.DelegateSupport |
---|
client, id, onewayClient, state, version |
Constructor Summary | |
---|---|
ClientSessionDelegate()
|
|
ClientSessionDelegate(java.lang.String objectID,
int dupsOKBatchSize)
|
Method Summary | |
---|---|
void |
acknowledgeAll()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
acknowledgeDeliveries(java.util.List acks)
Acknowledge a list of deliveries |
boolean |
acknowledgeDelivery(Ack ack)
Acknowledge a delivery |
void |
addAsfMessage(MessageProxy m,
java.lang.String consumerID,
java.lang.String queueName,
int maxDeliveries,
SessionDelegate connectionConsumerSession,
boolean shouldAck)
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
addTemporaryDestination(JBossDestination destination)
Add a temporary destination. |
void |
cancelDeliveries(java.util.List cancels)
Cancel a list of deliveries. |
void |
cancelDelivery(Cancel cancel)
Cancel a delivery |
void |
close()
Close the instance |
long |
closing(long sequence)
Tell the instance to prepare to close |
void |
commit()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
BrowserDelegate |
createBrowserDelegate(JBossDestination queue,
java.lang.String messageSelector)
|
BytesMessageProxy |
createBytesMessage()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
ConsumerDelegate |
createConsumerDelegate(JBossDestination destination,
java.lang.String selector,
boolean noLocal,
java.lang.String subscriptionName,
boolean connectionConsumer,
boolean started)
|
MapMessageProxy |
createMapMessage()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
MessageProxy |
createMessage()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
ObjectMessageProxy |
createObjectMessage()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
ObjectMessageProxy |
createObjectMessage(java.io.Serializable object)
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
ProducerDelegate |
createProducerDelegate(JBossDestination destination)
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
JBossQueue |
createQueue(java.lang.String queueName)
Creates a queue identity given a Queue name. |
StreamMessageProxy |
createStreamMessage()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
TextMessageProxy |
createTextMessage()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
TextMessageProxy |
createTextMessage(java.lang.String text)
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
JBossTopic |
createTopic(java.lang.String topicName)
Creates a topic identity given a Queue name. |
void |
deleteTemporaryDestination(JBossDestination destination)
Delete a temporary destination |
int |
getAcknowledgeMode()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
int |
getDupsOKBatchSize()
|
javax.jms.MessageListener |
getMessageListener()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
boolean |
getTransacted()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
javax.transaction.xa.XAResource |
getXAResource()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
boolean |
postDeliver()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
preDeliver(DeliveryInfo deliveryInfo)
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
read(java.io.DataInputStream in)
|
void |
recover()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
recoverDeliveries(java.util.List acks,
java.lang.String sessionID)
Send delivery info to the server so the delivery lists can be repopulated. |
void |
redeliver()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
redeliver(java.util.List ackInfos)
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
rollback()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
run()
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
send(JBossMessage m,
boolean checkForDuplicates)
Send a message |
void |
setMessageListener(javax.jms.MessageListener listener)
This invocation should either be handled by the client-side interceptor chain or by the server-side endpoint. |
void |
setState(HierarchicalState state)
|
void |
synchronizeWith(DelegateSupport nd)
During HA events, delegates corresponding to new enpoints on the new server are created and the state of those delegates has to be transfered to the "failed" delegates. |
java.lang.String |
toString()
|
void |
unsubscribe(java.lang.String subscriptionName)
Unsubscribe the client from the durable subscription specified by subscriptionName |
void |
write(java.io.DataOutputStream out)
|
Methods inherited from class org.jboss.jms.client.delegate.DelegateSupport |
---|
doInvoke, doInvokeOneway, getClient, getID, getName, getState, handleThrowable |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public ClientSessionDelegate(java.lang.String objectID, int dupsOKBatchSize)
public ClientSessionDelegate()
Method Detail |
---|
public void synchronizeWith(DelegateSupport nd) throws java.lang.Exception
DelegateSupport
synchronizeWith
in class DelegateSupport
java.lang.Exception
public void setState(HierarchicalState state)
setState
in class DelegateSupport
public void close() throws javax.jms.JMSException
Closeable
close
in interface Closeable
javax.jms.JMSException
public long closing(long sequence) throws javax.jms.JMSException
Closeable
closing
in interface Closeable
javax.jms.JMSException
public boolean acknowledgeDelivery(Ack ack) throws javax.jms.JMSException
SessionEndpoint
acknowledgeDelivery
in interface SessionEndpoint
javax.jms.JMSException
public void acknowledgeDeliveries(java.util.List acks) throws javax.jms.JMSException
SessionEndpoint
acknowledgeDeliveries
in interface SessionEndpoint
javax.jms.JMSException
public void acknowledgeAll() throws javax.jms.JMSException
acknowledgeAll
in interface SessionDelegate
javax.jms.JMSException
public void addTemporaryDestination(JBossDestination destination) throws javax.jms.JMSException
SessionEndpoint
addTemporaryDestination
in interface SessionEndpoint
javax.jms.JMSException
public void redeliver() throws javax.jms.JMSException
javax.jms.JMSException
public void commit() throws javax.jms.JMSException
commit
in interface SessionDelegate
javax.jms.JMSException
public BrowserDelegate createBrowserDelegate(JBossDestination queue, java.lang.String messageSelector) throws javax.jms.JMSException
createBrowserDelegate
in interface SessionEndpoint
javax.jms.JMSException
public BytesMessageProxy createBytesMessage() throws javax.jms.JMSException
createBytesMessage
in interface SessionDelegate
javax.jms.JMSException
public ConsumerDelegate createConsumerDelegate(JBossDestination destination, java.lang.String selector, boolean noLocal, java.lang.String subscriptionName, boolean connectionConsumer, boolean started) throws javax.jms.JMSException
createConsumerDelegate
in interface SessionEndpoint
javax.jms.JMSException
public MapMessageProxy createMapMessage() throws javax.jms.JMSException
createMapMessage
in interface SessionDelegate
javax.jms.JMSException
public MessageProxy createMessage() throws javax.jms.JMSException
createMessage
in interface SessionDelegate
javax.jms.JMSException
public ObjectMessageProxy createObjectMessage() throws javax.jms.JMSException
createObjectMessage
in interface SessionDelegate
javax.jms.JMSException
public ObjectMessageProxy createObjectMessage(java.io.Serializable object) throws javax.jms.JMSException
createObjectMessage
in interface SessionDelegate
javax.jms.JMSException
public ProducerDelegate createProducerDelegate(JBossDestination destination) throws javax.jms.JMSException
createProducerDelegate
in interface SessionDelegate
javax.jms.JMSException
public JBossQueue createQueue(java.lang.String queueName) throws javax.jms.JMSException
SessionEndpoint
createQueue
in interface SessionEndpoint
javax.jms.JMSException
public StreamMessageProxy createStreamMessage() throws javax.jms.JMSException
createStreamMessage
in interface SessionDelegate
javax.jms.JMSException
public TextMessageProxy createTextMessage() throws javax.jms.JMSException
createTextMessage
in interface SessionDelegate
javax.jms.JMSException
public TextMessageProxy createTextMessage(java.lang.String text) throws javax.jms.JMSException
createTextMessage
in interface SessionDelegate
javax.jms.JMSException
public JBossTopic createTopic(java.lang.String topicName) throws javax.jms.JMSException
SessionEndpoint
createTopic
in interface SessionEndpoint
javax.jms.JMSException
public void deleteTemporaryDestination(JBossDestination destination) throws javax.jms.JMSException
SessionEndpoint
deleteTemporaryDestination
in interface SessionEndpoint
javax.jms.JMSException
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
getMessageListener
in interface SessionDelegate
javax.jms.JMSException
public boolean postDeliver() throws javax.jms.JMSException
postDeliver
in interface SessionDelegate
javax.jms.JMSException
public void preDeliver(DeliveryInfo deliveryInfo) throws javax.jms.JMSException
preDeliver
in interface SessionDelegate
javax.jms.JMSException
public void recover() throws javax.jms.JMSException
recover
in interface SessionDelegate
javax.jms.JMSException
public void redeliver(java.util.List ackInfos) throws javax.jms.JMSException
redeliver
in interface SessionDelegate
javax.jms.JMSException
public void rollback() throws javax.jms.JMSException
rollback
in interface SessionDelegate
javax.jms.JMSException
public void run()
run
in interface SessionDelegate
public void setMessageListener(javax.jms.MessageListener listener) throws javax.jms.JMSException
setMessageListener
in interface SessionDelegate
javax.jms.JMSException
public void unsubscribe(java.lang.String subscriptionName) throws javax.jms.JMSException
SessionEndpoint
unsubscribe
in interface SessionEndpoint
subscriptionName
- the Name of the durable subscription to unsubscribe from
javax.jms.JMSException
- if the unsubscribe failspublic javax.transaction.xa.XAResource getXAResource()
getXAResource
in interface SessionDelegate
public int getAcknowledgeMode()
getAcknowledgeMode
in interface SessionDelegate
public boolean getTransacted()
getTransacted
in interface SessionDelegate
public void addAsfMessage(MessageProxy m, java.lang.String consumerID, java.lang.String queueName, int maxDeliveries, SessionDelegate connectionConsumerSession, boolean shouldAck)
addAsfMessage
in interface SessionDelegate
public void send(JBossMessage m, boolean checkForDuplicates) throws javax.jms.JMSException
SessionEndpoint
send
in interface SessionEndpoint
m
- The message to send
javax.jms.JMSException
public void cancelDeliveries(java.util.List cancels) throws javax.jms.JMSException
SessionEndpoint
cancelDeliveries
in interface SessionEndpoint
javax.jms.JMSException
public void cancelDelivery(Cancel cancel) throws javax.jms.JMSException
SessionEndpoint
cancelDelivery
in interface SessionEndpoint
javax.jms.JMSException
public void recoverDeliveries(java.util.List acks, java.lang.String sessionID) throws javax.jms.JMSException
SessionEndpoint
recoverDeliveries
in interface SessionEndpoint
javax.jms.JMSException
public void read(java.io.DataInputStream in) throws java.lang.Exception
read
in interface Streamable
read
in class DelegateSupport
java.lang.Exception
public void write(java.io.DataOutputStream out) throws java.lang.Exception
write
in interface Streamable
write
in class DelegateSupport
java.lang.Exception
public int getDupsOKBatchSize()
public java.lang.String toString()
toString
in class java.lang.Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |