org.apache.activemq.transport.stomp
public class StompConnection extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static long |
RECEIVE_TIMEOUT |
Constructor and Description |
---|
StompConnection() |
Modifier and Type | Method and Description |
---|---|
void |
abort(java.lang.String transaction) |
void |
ack(StompFrame frame) |
void |
ack(StompFrame frame,
java.lang.String transaction) |
void |
ack(java.lang.String messageId) |
void |
ack(java.lang.String messageId,
java.lang.String transaction) |
protected java.lang.String |
appendHeaders(java.util.HashMap<java.lang.String,java.lang.Object> headers) |
void |
begin(java.lang.String transaction) |
void |
close() |
void |
commit(java.lang.String transaction) |
void |
connect(java.lang.String username,
java.lang.String password) |
void |
connect(java.lang.String username,
java.lang.String password,
java.lang.String client) |
void |
disconnect() |
java.net.Socket |
getStompSocket() |
void |
open(java.net.Socket socket) |
void |
open(java.lang.String host,
int port) |
StompFrame |
receive() |
StompFrame |
receive(long timeOut) |
java.lang.String |
receiveFrame() |
java.lang.String |
receiveFrame(long timeOut) |
void |
send(java.lang.String destination,
java.lang.String message) |
void |
send(java.lang.String destination,
java.lang.String message,
java.lang.String transaction,
java.util.HashMap<java.lang.String,java.lang.String> headers) |
void |
sendFrame(java.lang.String data) |
void |
sendFrame(java.lang.String frame,
byte[] data) |
void |
setStompSocket(java.net.Socket stompSocket) |
void |
subscribe(java.lang.String destination) |
void |
subscribe(java.lang.String destination,
java.lang.String ack) |
void |
subscribe(java.lang.String destination,
java.lang.String ack,
java.util.HashMap<java.lang.String,java.lang.String> headers) |
void |
unsubscribe(java.lang.String destination) |
void |
unsubscribe(java.lang.String destination,
java.util.HashMap<java.lang.String,java.lang.String> headers) |
public static final long RECEIVE_TIMEOUT
public StompConnection()
public void open(java.lang.String host, int port) throws java.io.IOException, java.net.UnknownHostException
java.io.IOException
java.net.UnknownHostException
public void open(java.net.Socket socket)
public void close() throws java.io.IOException
java.io.IOException
public void sendFrame(java.lang.String data) throws java.lang.Exception
java.lang.Exception
public void sendFrame(java.lang.String frame, byte[] data) throws java.lang.Exception
java.lang.Exception
public StompFrame receive() throws java.lang.Exception
java.lang.Exception
public StompFrame receive(long timeOut) throws java.lang.Exception
java.lang.Exception
public java.lang.String receiveFrame() throws java.lang.Exception
java.lang.Exception
public java.lang.String receiveFrame(long timeOut) throws java.lang.Exception
java.lang.Exception
public java.net.Socket getStompSocket()
public void setStompSocket(java.net.Socket stompSocket)
public void connect(java.lang.String username, java.lang.String password) throws java.lang.Exception
java.lang.Exception
public void connect(java.lang.String username, java.lang.String password, java.lang.String client) throws java.lang.Exception
java.lang.Exception
public void disconnect() throws java.lang.Exception
java.lang.Exception
public void send(java.lang.String destination, java.lang.String message) throws java.lang.Exception
java.lang.Exception
public void send(java.lang.String destination, java.lang.String message, java.lang.String transaction, java.util.HashMap<java.lang.String,java.lang.String> headers) throws java.lang.Exception
java.lang.Exception
public void subscribe(java.lang.String destination) throws java.lang.Exception
java.lang.Exception
public void subscribe(java.lang.String destination, java.lang.String ack) throws java.lang.Exception
java.lang.Exception
public void subscribe(java.lang.String destination, java.lang.String ack, java.util.HashMap<java.lang.String,java.lang.String> headers) throws java.lang.Exception
java.lang.Exception
public void unsubscribe(java.lang.String destination) throws java.lang.Exception
java.lang.Exception
public void unsubscribe(java.lang.String destination, java.util.HashMap<java.lang.String,java.lang.String> headers) throws java.lang.Exception
java.lang.Exception
public void begin(java.lang.String transaction) throws java.lang.Exception
java.lang.Exception
public void abort(java.lang.String transaction) throws java.lang.Exception
java.lang.Exception
public void commit(java.lang.String transaction) throws java.lang.Exception
java.lang.Exception
public void ack(StompFrame frame) throws java.lang.Exception
java.lang.Exception
public void ack(StompFrame frame, java.lang.String transaction) throws java.lang.Exception
java.lang.Exception
public void ack(java.lang.String messageId) throws java.lang.Exception
java.lang.Exception
public void ack(java.lang.String messageId, java.lang.String transaction) throws java.lang.Exception
java.lang.Exception
protected java.lang.String appendHeaders(java.util.HashMap<java.lang.String,java.lang.Object> headers)
Copyright © 2005-2014. All Rights Reserved.