|
||||||||||
| PREV CLASS (src) NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.jboss.jms.client.p2p.P2PSessionDelegate
The p2p session
| Constructor Summary | |
P2PSessionDelegate(P2PConnectionDelegate (src) connection,
boolean transaction,
int acknowledgeMode)
|
|
| Method Summary | |
void |
acknowledge(Message (src) message,
boolean acknowledge)
Acknowledge a message |
void |
close()
Close the delegate |
void |
closing()
Notify about to close |
void |
commit()
Commit a session |
BrowserDelegate (src) |
createBrowser(Queue (src) queue,
java.lang.String selector)
Create a queue browser |
BytesMessage (src) |
createBytesMessage()
Create a bytes message |
ConsumerDelegate (src) |
createConsumer(Destination (src) destination,
java.lang.String subscription,
java.lang.String selector,
boolean noLocal)
Create a consumer |
MapMessage (src) |
createMapMessage()
Create a map message |
Message (src) |
createMessage()
Create a message |
ObjectMessage (src) |
createObjectMessage(java.io.Serializable object)
Create an object message |
ProducerDelegate (src) |
createProducer(Destination (src) destination)
Create a producer |
StreamMessage (src) |
createStreamMessage()
Create a stream message |
Destination (src) |
createTempDestination(int type)
Create a temporary destination |
TextMessage (src) |
createTextMessage(java.lang.String text)
Create a text message |
Destination (src) |
getDestination(java.lang.String name)
Retrieve a destination |
XAResource (src) |
getXAResource()
Retrieve the XAResource for this session |
void |
recover()
Recover a session |
void |
rollback()
Rollback a session |
void |
run()
Run the session listener |
void |
setMessageListener(MessageListener (src) listener)
Set the session's message listener |
void |
unsubscribe(java.lang.String name)
Unsubscribe the name |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
public P2PSessionDelegate(P2PConnectionDelegate (src) connection,
boolean transaction,
int acknowledgeMode)
throws JMSException (src)
| Method Detail |
public void close()
throws JMSException (src)
Lifecycle (src)
close in interface Lifecycle (src) JMSException (src) - for any error
public void closing()
throws JMSException (src)
Lifecycle (src)
closing in interface Lifecycle (src) JMSException (src) - for any error
public void commit()
throws JMSException (src)
SessionDelegate (src)
commit in interface SessionDelegate (src) JMSException (src) - for any error
public BrowserDelegate (src) createBrowser(Queue (src) queue,
java.lang.String selector)
throws JMSException (src)
SessionDelegate (src)
createBrowser in interface SessionDelegate (src) queue - the queueselector - the message selector
JMSException (src) - for any error
public BytesMessage (src) createBytesMessage()
throws JMSException (src)
SessionDelegate (src)
createBytesMessage in interface SessionDelegate (src) JMSException (src) - for any error
public ConsumerDelegate (src) createConsumer(Destination (src) destination,
java.lang.String subscription,
java.lang.String selector,
boolean noLocal)
throws JMSException (src)
SessionDelegate (src)
createConsumer in interface SessionDelegate (src) destination - the destinationsubscription - the subscription nameselector - the message selectornoLocal - the no local flag
JMSException (src) - for any error
public MapMessage (src) createMapMessage()
throws JMSException (src)
SessionDelegate (src)
createMapMessage in interface SessionDelegate (src) JMSException (src) - for any error
public Message (src) createMessage()
throws JMSException (src)
SessionDelegate (src)
createMessage in interface SessionDelegate (src) JMSException (src) - for any error
public ObjectMessage (src) createObjectMessage(java.io.Serializable object)
throws JMSException (src)
SessionDelegate (src)
createObjectMessage in interface SessionDelegate (src) object - the object
JMSException (src) - for any error
public ProducerDelegate (src) createProducer(Destination (src) destination)
throws JMSException (src)
SessionDelegate (src)
createProducer in interface SessionDelegate (src) destination - the destination
JMSException (src) - for any error
public StreamMessage (src) createStreamMessage()
throws JMSException (src)
SessionDelegate (src)
createStreamMessage in interface SessionDelegate (src) JMSException (src) - for any error
public Destination (src) createTempDestination(int type)
throws JMSException (src)
SessionDelegate (src)
createTempDestination in interface SessionDelegate (src) type - the type of temporary destination
JMSException (src) - for any error
public TextMessage (src) createTextMessage(java.lang.String text)
throws JMSException (src)
SessionDelegate (src)
createTextMessage in interface SessionDelegate (src) text - the text
JMSException (src) - for any error
public Destination (src) getDestination(java.lang.String name)
throws JMSException (src)
SessionDelegate (src)
getDestination in interface SessionDelegate (src) name - the implementation dependent name
JMSException (src) - for any errorpublic XAResource (src) getXAResource()
SessionDelegate (src)
getXAResource in interface SessionDelegate (src)
public void recover()
throws JMSException (src)
SessionDelegate (src)
recover in interface SessionDelegate (src) JMSException (src) - for any error
public void rollback()
throws JMSException (src)
SessionDelegate (src)
rollback in interface SessionDelegate (src) JMSException (src) - for any errorpublic void run()
SessionDelegate (src)
run in interface SessionDelegate (src)
public void setMessageListener(MessageListener (src) listener)
throws JMSException (src)
SessionDelegate (src)
setMessageListener in interface SessionDelegate (src) listener - the message listener
JMSException (src) - for any error
public void unsubscribe(java.lang.String name)
throws JMSException (src)
SessionDelegate (src)
unsubscribe in interface SessionDelegate (src) name - the name of the subscription
JMSException (src) - for any error
public void acknowledge(Message (src) message,
boolean acknowledge)
SessionDelegate (src)
acknowledge in interface SessionDelegate (src) message - the message to acknowledgeacknowledge - true for acknowledge, false for a Nack
|
||||||||||
| PREV CLASS (src) NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||