|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.atomikos.icatch.msg.AbstractTransport
public abstract class AbstractTransport
Field Summary |
---|
Fields inherited from interface com.atomikos.icatch.msg.Transport |
---|
FTP, HTTP, JMS, SMTP, UNKNOWN_PROTOCOL |
Constructor Summary | |
---|---|
protected |
AbstractTransport(String name,
String participantAddress,
String coordinatorAddress,
int commitProtocol,
int transportProtocol,
int format,
long defaultTimeout)
|
Method Summary | |
---|---|
void |
close()
Closes the resource for shutdown. |
CommitMessage |
createCommitMessage(boolean onephase,
String senderURI,
String targetURI,
Object targetAddress)
Create a new commit message. |
ErrorMessage |
createErrorMessage(int code,
String senderURI,
String targetURI,
Object targetAddress)
Create a new error message. |
ForgetMessage |
createForgetMessage(String senderURI,
String targetURI,
Object targetAddress)
Create a new forget message. |
PreparedMessage |
createPreparedMessage(boolean readonly,
String senderURI,
String targetURI,
Object targetAddress)
Create a new prepared message. |
PrepareMessage |
createPrepareMessage(int globalSiblingCount,
CascadeInfo[] cascadeInfo,
String senderURI,
String targetURI,
Object targetAddress)
Create a new prepare message. |
PrepareMessage |
createPrepareMessage(String senderURI,
String targetURI,
Object targetAddress)
Create a new prepare message. |
RegisteredMessage |
createRegisteredMessage(String senderURI,
String targetURI,
Object targetAddress)
Create a new registration confirmation message. |
RegisterMessage |
createRegisterMessage(String senderURI,
String targetURI,
Object targetAddress,
boolean for2PC)
Create a new registration message. |
ReplayMessage |
createReplayMessage(String senderURI,
String targetURI,
Object targetAddress)
Create a new replay message. |
RollbackMessage |
createRollbackMessage(String senderURI,
String targetURI,
Object targetAddress)
Create a new rollback message. |
StateMessage |
createStateMessage(Boolean committed,
String senderURI,
String targetURI,
Object targetAddress)
Create a new state message. |
void |
endRecovery()
Notifies the resource that recovery is ended. |
int |
getCommitProtocol()
The protocol that this transport understands. |
String |
getCoordinatorAddress()
Get the address on which this transport is listening for incoming coordinator messages. |
long |
getDefaultTimeout()
Get a realistic default timeout for the given transport. |
int |
getFormat()
Get the message format that this transport understands. |
String |
getName()
Gets the name of the resource. |
String |
getParticipantAddress()
Get the address on which this transport is listening for incoming participant messages. |
int |
getTransportProtocol()
Get the transport protocol that this transport understands. |
boolean |
isClosed()
Tests if the resource is closed. |
boolean |
isSameRM(RecoverableResource res)
Tests if a resource is the same as another one. |
boolean |
recover(Participant participant)
Recovers the partially reconstructed Participant. |
void |
registerMessageListener(MessageListener listener)
Register a message listener for unexpected receivals. |
void |
registerMessageListener(MessageListener listener,
int messageType)
Register a message listener for incoming messages of the given type. |
void |
removeMessageListener(MessageListener listener)
Remove a previously registered listener. |
protected void |
replyReceived(TransactionMessage reply)
Notification that a reply has come in. |
protected void |
requestReceived(TransactionMessage req)
Notification that a request has come in. |
void |
send(TransactionMessage msg)
Send a message. |
TransactionMessage |
sendAndReceive(TransactionMessage msg,
long timeout,
int[] expected)
Send and receive a message for the given target. |
void |
setRecoveryService(RecoveryService recoveryService)
Initializes this resource with the recovery service. |
void |
setSenderPort(SenderPort senderPort)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected AbstractTransport(String name, String participantAddress, String coordinatorAddress, int commitProtocol, int transportProtocol, int format, long defaultTimeout)
Method Detail |
---|
protected void replyReceived(TransactionMessage reply)
reply
- The incoming reply message.protected void requestReceived(TransactionMessage req)
req
- The incoming request message.public int getCommitProtocol()
Transport
getCommitProtocol
in interface Transport
Transport.getCommitProtocol()
public int getFormat()
Transport
getFormat
in interface Transport
Transport.getFormat()
public void setSenderPort(SenderPort senderPort)
public int getTransportProtocol()
Transport
getTransportProtocol
in interface Transport
Transport.getTransportProtocol()
public long getDefaultTimeout()
Transport
getDefaultTimeout
in interface Transport
Transport.getDefaultTimeout()
public TransactionMessage sendAndReceive(TransactionMessage msg, long timeout, int[] expected) throws TransportException, IllegalMessageTypeException
Transport
sendAndReceive
in interface Transport
msg
- The message to send.timeout
- The timeout in milliseconds after which the method will
return, received or not.expected
- The types of messages expected. Other messages are ignored.
The values should be of TransactionMessage's predefined types.
IllegalMessageTypeException
- If the message sent is of the wrong type.
TransportException
Transport.sendAndReceive(com.atomikos.icatch.msg.TransactionMessage,
long, int[])
public void registerMessageListener(MessageListener listener) throws TransportException
Transport
registerMessageListener
in interface Transport
listener
- The message listener.
TransportException
- On failure.Transport.registerMessageListener(com.atomikos.icatch.msg.MessageListener)
public void registerMessageListener(MessageListener listener, int messageType) throws TransportException
Transport
registerMessageListener
in interface Transport
listener
- The listener.messageType
- The type to listen for.
TransportException
- On failure.Transport.registerMessageListener(com.atomikos.icatch.msg.MessageListener,
int)
public void removeMessageListener(MessageListener listener) throws TransportException
Transport
removeMessageListener
in interface Transport
listener
- The message listener.
TransportException
- On failure.Transport.removeMessageListener(com.atomikos.icatch.msg.MessageListener)
public boolean recover(Participant participant) throws ResourceException
RecoverableResource
recover
in interface RecoverableResource
participant
- A partially recovered Participant.
ResourceException
- On failure.RecoverableResource.recover(com.atomikos.icatch.Participant)
public void endRecovery() throws ResourceException
RecoverableResource
endRecovery
in interface RecoverableResource
ResourceException
- On failure.RecoverableResource.endRecovery()
public void close() throws ResourceException
RecoverableResource
close
in interface RecoverableResource
ResourceException
RecoverableResource.close()
public String getName()
RecoverableResource
getName
in interface RecoverableResource
RecoverableResource.getName()
public boolean isSameRM(RecoverableResource res) throws ResourceException
RecoverableResource
isSameRM
in interface RecoverableResource
ResourceException
RecoverableResource.isSameRM(com.atomikos.datasource.RecoverableResource)
public CommitMessage createCommitMessage(boolean onephase, String senderURI, String targetURI, Object targetAddress)
createCommitMessage
in interface Transport
public ErrorMessage createErrorMessage(int code, String senderURI, String targetURI, Object targetAddress)
createErrorMessage
in interface Transport
public ForgetMessage createForgetMessage(String senderURI, String targetURI, Object targetAddress)
createForgetMessage
in interface Transport
public PrepareMessage createPrepareMessage(String senderURI, String targetURI, Object targetAddress)
createPrepareMessage
in interface Transport
public PrepareMessage createPrepareMessage(int globalSiblingCount, CascadeInfo[] cascadeInfo, String senderURI, String targetURI, Object targetAddress)
createPrepareMessage
in interface Transport
public PreparedMessage createPreparedMessage(boolean readonly, String senderURI, String targetURI, Object targetAddress)
createPreparedMessage
in interface Transport
public ReplayMessage createReplayMessage(String senderURI, String targetURI, Object targetAddress)
createReplayMessage
in interface Transport
public RollbackMessage createRollbackMessage(String senderURI, String targetURI, Object targetAddress)
createRollbackMessage
in interface Transport
public StateMessage createStateMessage(Boolean committed, String senderURI, String targetURI, Object targetAddress)
createStateMessage
in interface Transport
public RegisterMessage createRegisterMessage(String senderURI, String targetURI, Object targetAddress, boolean for2PC)
createRegisterMessage
in interface Transport
public RegisteredMessage createRegisteredMessage(String senderURI, String targetURI, Object targetAddress)
createRegisteredMessage
in interface Transport
public String getCoordinatorAddress()
Transport
getCoordinatorAddress
in interface Transport
getCoordinatorAddress()
public String getParticipantAddress()
Transport
getParticipantAddress
in interface Transport
getParticipantAddress()
public boolean isClosed()
RecoverableResource
isClosed
in interface RecoverableResource
public void setRecoveryService(RecoveryService recoveryService) throws ResourceException
RecoverableResource
setRecoveryService
in interface RecoverableResource
recoveryService
- The recovery service. This instance
can be used by the resource to ask recovery from the
transaction engine.
ResourceException
- On errors.public void send(TransactionMessage msg) throws TransportException, IllegalMessageTypeException
Transport
send
in interface Transport
msg
- The message to send.
TransportException
- On failure.
IllegalMessageTypeException
- If the message sent is of the wrong type.Transport.send(com.atomikos.icatch.msg.TransactionMessage)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |