|
Spring AMQP | |||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.springframework.erlang.connection.DefaultConnection
public class DefaultConnection
Basic implementation of ConnectionProxy that delegates to an underlying OtpConnection.
| Constructor Summary | |
|---|---|
DefaultConnection(com.ericsson.otp.erlang.OtpConnection otpConnection)
|
|
| Method Summary | |
|---|---|
void |
close()
Close the connection to the remote node. |
com.ericsson.otp.erlang.OtpConnection |
getTargetConnection()
|
com.ericsson.otp.erlang.OtpErlangObject |
receiveRPC()
Receive an RPC reply from the remote Erlang node. |
void |
sendRPC(String mod,
String fun,
com.ericsson.otp.erlang.OtpErlangList args)
Send an RPC request to the remote Erlang node. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public DefaultConnection(com.ericsson.otp.erlang.OtpConnection otpConnection)
| Method Detail |
|---|
public void close()
Connection
close in interface Connection
public void sendRPC(String mod,
String fun,
com.ericsson.otp.erlang.OtpErlangList args)
throws IOException
Connection
{ self, { call, Mod, Fun, Args, user } }
Note that this method has unpredicatble results if the remote node is not an Erlang node.
sendRPC in interface Connectionmod - the name of the Erlang module containing the function to
be called.fun - the name of the function to call.args - a list of Erlang terms, to be used as arguments to the
function.
IOException - if the connection is not active or a communication
error occurs.
public com.ericsson.otp.erlang.OtpErlangObject receiveRPC()
throws IOException,
com.ericsson.otp.erlang.OtpErlangExit,
com.ericsson.otp.erlang.OtpAuthException
Connection
{ rex, Term }
receiveRPC in interface ConnectionIOException - if the connection is not active or a communication
error occurs.
com.ericsson.otp.erlang.OtpErlangExit - if an exit signal is received from a process on the
peer node.
com.ericsson.otp.erlang.OtpAuthException - if the remote node sends a message containing an
invalid cookie.public com.ericsson.otp.erlang.OtpConnection getTargetConnection()
getTargetConnection in interface ConnectionProxy
|
Spring AMQP | |||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||