org.apache.activemq.transport.stomp
Class StompConnection
java.lang.Object
org.apache.activemq.transport.stomp.StompConnection
public class StompConnection
- extends java.lang.Object
Method Summary |
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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RECEIVE_TIMEOUT
public static final long RECEIVE_TIMEOUT
- See Also:
- Constant Field Values
StompConnection
public StompConnection()
open
public void open(java.lang.String host,
int port)
throws java.io.IOException,
java.net.UnknownHostException
- Throws:
java.io.IOException
java.net.UnknownHostException
open
public void open(java.net.Socket socket)
close
public void close()
throws java.io.IOException
- Throws:
java.io.IOException
sendFrame
public void sendFrame(java.lang.String data)
throws java.lang.Exception
- Throws:
java.lang.Exception
sendFrame
public void sendFrame(java.lang.String frame,
byte[] data)
throws java.lang.Exception
- Throws:
java.lang.Exception
receive
public StompFrame receive()
throws java.lang.Exception
- Throws:
java.lang.Exception
receive
public StompFrame receive(long timeOut)
throws java.lang.Exception
- Throws:
java.lang.Exception
receiveFrame
public java.lang.String receiveFrame()
throws java.lang.Exception
- Throws:
java.lang.Exception
receiveFrame
public java.lang.String receiveFrame(long timeOut)
throws java.lang.Exception
- Throws:
java.lang.Exception
getStompSocket
public java.net.Socket getStompSocket()
setStompSocket
public void setStompSocket(java.net.Socket stompSocket)
connect
public void connect(java.lang.String username,
java.lang.String password)
throws java.lang.Exception
- Throws:
java.lang.Exception
connect
public void connect(java.lang.String username,
java.lang.String password,
java.lang.String client)
throws java.lang.Exception
- Throws:
java.lang.Exception
disconnect
public void disconnect()
throws java.lang.Exception
- Throws:
java.lang.Exception
send
public void send(java.lang.String destination,
java.lang.String message)
throws java.lang.Exception
- Throws:
java.lang.Exception
send
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
- Throws:
java.lang.Exception
subscribe
public void subscribe(java.lang.String destination)
throws java.lang.Exception
- Throws:
java.lang.Exception
subscribe
public void subscribe(java.lang.String destination,
java.lang.String ack)
throws java.lang.Exception
- Throws:
java.lang.Exception
subscribe
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
- Throws:
java.lang.Exception
unsubscribe
public void unsubscribe(java.lang.String destination)
throws java.lang.Exception
- Throws:
java.lang.Exception
unsubscribe
public void unsubscribe(java.lang.String destination,
java.util.HashMap<java.lang.String,java.lang.String> headers)
throws java.lang.Exception
- Throws:
java.lang.Exception
begin
public void begin(java.lang.String transaction)
throws java.lang.Exception
- Throws:
java.lang.Exception
abort
public void abort(java.lang.String transaction)
throws java.lang.Exception
- Throws:
java.lang.Exception
commit
public void commit(java.lang.String transaction)
throws java.lang.Exception
- Throws:
java.lang.Exception
ack
public void ack(StompFrame frame)
throws java.lang.Exception
- Throws:
java.lang.Exception
ack
public void ack(StompFrame frame,
java.lang.String transaction)
throws java.lang.Exception
- Throws:
java.lang.Exception
ack
public void ack(java.lang.String messageId)
throws java.lang.Exception
- Throws:
java.lang.Exception
ack
public void ack(java.lang.String messageId,
java.lang.String transaction)
throws java.lang.Exception
- Throws:
java.lang.Exception
appendHeaders
protected java.lang.String appendHeaders(java.util.HashMap<java.lang.String,java.lang.Object> headers)
Copyright © 2005-2012. All Rights Reserved.