|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.softwareag.sagd.PMQServer.PMQInterfaceDispatcher com.softwareag.jca.PMQMessageStreamDispatcher
public class PMQMessageStreamDispatcher
Implements message dispatcher for PMQMessageServer
and supports the XA protocol. The message driven bean can open a distributed transaction
and the dispatched message can be commited or rollbacked inside the transaction.
Field Summary |
---|
Fields inherited from interface javax.transaction.xa.XAResource |
---|
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY |
Constructor Summary | |
---|---|
protected |
PMQMessageStreamDispatcher(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory)
Create dispatcher for meassage driven bean. |
Method Summary | |
---|---|
void |
commit(javax.transaction.xa.Xid arg0,
boolean arg1)
XA callback. |
boolean |
doDispatch(java.io.InputStream input,
java.io.OutputStream output)
Callback from PMQMessageServer . |
void |
doLog(boolean flag,
java.lang.String message)
Implements local logging. |
void |
end(javax.transaction.xa.Xid arg0,
int arg1)
XA callback. |
void |
forget(javax.transaction.xa.Xid arg0)
XA callback. |
int |
getTransactionTimeout()
XA callback. |
boolean |
isSameRM(javax.transaction.xa.XAResource arg0)
XA callback. |
int |
prepare(javax.transaction.xa.Xid arg0)
XA callback. |
javax.transaction.xa.Xid[] |
recover(int arg0)
XA callback. |
void |
rollback(javax.transaction.xa.Xid arg0)
XA callback. |
boolean |
setTransactionTimeout(int arg0)
XA callback. |
void |
start(javax.transaction.xa.Xid arg0,
int arg1)
XA callback. |
Methods inherited from class com.softwareag.sagd.PMQServer.PMQInterfaceDispatcher |
---|
doDispatch, doInit, doInit, doLog, doRelease, getLifetime, getPersistentStatusFlagChanged, getStatusPersistence, isSingleMessageDispatcher, isStreamSendResponseDispatcher, setLifetime, setSingleMessageDispatcher, setStatusPersistence, setStreamSendResponseDispatcher |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected PMQMessageStreamDispatcher(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory)
endpointFactory
- message receiverMethod Detail |
---|
public boolean doDispatch(java.io.InputStream input, java.io.OutputStream output)
PMQMessageServer
.
doDispatch
in class PMQInterfaceDispatcher
input
- streamoutput
- response stream
true
to commit the message. false
does a backout and stops the server.public int getTransactionTimeout() throws javax.transaction.xa.XAException
getTransactionTimeout
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public boolean setTransactionTimeout(int arg0) throws javax.transaction.xa.XAException
setTransactionTimeout
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public boolean isSameRM(javax.transaction.xa.XAResource arg0) throws javax.transaction.xa.XAException
isSameRM
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public javax.transaction.xa.Xid[] recover(int arg0) throws javax.transaction.xa.XAException
recover
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public int prepare(javax.transaction.xa.Xid arg0) throws javax.transaction.xa.XAException
prepare
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void forget(javax.transaction.xa.Xid arg0) throws javax.transaction.xa.XAException
forget
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void rollback(javax.transaction.xa.Xid arg0) throws javax.transaction.xa.XAException
rollback
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void end(javax.transaction.xa.Xid arg0, int arg1) throws javax.transaction.xa.XAException
end
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void start(javax.transaction.xa.Xid arg0, int arg1) throws javax.transaction.xa.XAException
start
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void commit(javax.transaction.xa.Xid arg0, boolean arg1) throws javax.transaction.xa.XAException
commit
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void doLog(boolean flag, java.lang.String message)
doLog
in class PMQInterfaceDispatcher
flag
- true
for information log levelmessage
- the message text
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |