|
||||||||||
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 errorpublic void closing() throws JMSException (src)
Lifecycle (src)
closing
in interface Lifecycle (src)
JMSException (src)
- for any errorpublic void commit() throws JMSException (src)
SessionDelegate (src)
commit
in interface SessionDelegate (src)
JMSException (src)
- for any errorpublic 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 errorpublic BytesMessage (src) createBytesMessage() throws JMSException (src)
SessionDelegate (src)
createBytesMessage
in interface SessionDelegate (src)
JMSException (src)
- for any errorpublic 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 errorpublic MapMessage (src) createMapMessage() throws JMSException (src)
SessionDelegate (src)
createMapMessage
in interface SessionDelegate (src)
JMSException (src)
- for any errorpublic Message (src) createMessage() throws JMSException (src)
SessionDelegate (src)
createMessage
in interface SessionDelegate (src)
JMSException (src)
- for any errorpublic ObjectMessage (src) createObjectMessage(java.io.Serializable object) throws JMSException (src)
SessionDelegate (src)
createObjectMessage
in interface SessionDelegate (src)
object
- the object
JMSException (src)
- for any errorpublic ProducerDelegate (src) createProducer(Destination (src) destination) throws JMSException (src)
SessionDelegate (src)
createProducer
in interface SessionDelegate (src)
destination
- the destination
JMSException (src)
- for any errorpublic StreamMessage (src) createStreamMessage() throws JMSException (src)
SessionDelegate (src)
createStreamMessage
in interface SessionDelegate (src)
JMSException (src)
- for any errorpublic 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 errorpublic TextMessage (src) createTextMessage(java.lang.String text) throws JMSException (src)
SessionDelegate (src)
createTextMessage
in interface SessionDelegate (src)
text
- the text
JMSException (src)
- for any errorpublic 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 errorpublic 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 errorpublic 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 errorpublic 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 |