org.jgroups.client
public class StompConnection extends java.lang.Object implements java.lang.Runnable
subscribe DEST // example: subscribe /topics/a send DEST message // example: send /topics/a Hello world[1] http://stomp.codehaus.org/Protocol
Modifier and Type | Class and Description |
---|---|
static interface |
StompConnection.Listener |
Modifier and Type | Field and Description |
---|---|
protected java.io.DataInputStream |
in |
protected java.util.Set<StompConnection.Listener> |
listeners |
protected Log |
log |
protected java.io.DataOutputStream |
out |
protected java.lang.Thread |
runner |
protected boolean |
running |
protected java.util.Set<java.lang.String> |
server_destinations |
protected java.lang.String |
session_id |
protected java.net.Socket |
sock |
protected java.util.Set<java.lang.String> |
subscriptions |
Constructor and Description |
---|
StompConnection(java.lang.String dest) |
Modifier and Type | Method and Description |
---|---|
void |
addListener(StompConnection.Listener listener) |
protected void |
close() |
void |
connect() |
protected void |
connect(java.lang.String dest) |
void |
connect(java.lang.String userid,
java.lang.String password) |
void |
disconnect() |
java.lang.String |
getSessionId() |
boolean |
isConnected() |
static void |
main(java.lang.String[] args) |
protected void |
notifyListeners(java.util.Map<java.lang.String,java.lang.String> info) |
protected void |
notifyListeners(java.util.Map<java.lang.String,java.lang.String> headers,
byte[] buf,
int offset,
int length) |
protected static java.net.SocketAddress |
parse(java.lang.String dest) |
protected java.lang.String |
pickRandomDestination() |
void |
reconnect() |
void |
removeListener(StompConnection.Listener listener) |
void |
run() |
void |
send(java.lang.String destination,
byte[] buf) |
void |
send(java.lang.String destination,
byte[] buf,
int offset,
int length) |
void |
send(java.lang.String destination,
byte[] buf,
int offset,
int length,
java.lang.String... headers) |
void |
send(java.lang.String destination,
java.lang.String... headers)
Sends an INFO without body
|
protected void |
startRunner() |
void |
subscribe(java.lang.String destination) |
void |
unsubscribe(java.lang.String destination) |
protected java.net.Socket sock
protected java.io.DataInputStream in
protected java.io.DataOutputStream out
protected final java.util.Set<java.lang.String> server_destinations
protected final java.util.Set<StompConnection.Listener> listeners
protected final java.util.Set<java.lang.String> subscriptions
protected java.lang.Thread runner
protected volatile boolean running
protected java.lang.String session_id
protected final Log log
public StompConnection(java.lang.String dest)
dest
- IP address + ':' + port, e.g. "192.168.1.5:8787"public java.lang.String getSessionId()
public void addListener(StompConnection.Listener listener)
public void removeListener(StompConnection.Listener listener)
public void connect(java.lang.String userid, java.lang.String password) throws java.io.IOException
java.io.IOException
public void reconnect() throws java.io.IOException
java.io.IOException
public void connect() throws java.io.IOException
java.io.IOException
public void disconnect()
public void subscribe(java.lang.String destination)
public void unsubscribe(java.lang.String destination)
public void send(java.lang.String destination, byte[] buf, int offset, int length, java.lang.String... headers)
public void send(java.lang.String destination, java.lang.String... headers)
public void send(java.lang.String destination, byte[] buf, int offset, int length)
public void send(java.lang.String destination, byte[] buf)
public void run()
run
in interface java.lang.Runnable
protected void notifyListeners(java.util.Map<java.lang.String,java.lang.String> headers, byte[] buf, int offset, int length)
protected void notifyListeners(java.util.Map<java.lang.String,java.lang.String> info)
protected java.lang.String pickRandomDestination()
protected void connect(java.lang.String dest) throws java.io.IOException
java.io.IOException
protected static java.net.SocketAddress parse(java.lang.String dest) throws java.net.UnknownHostException
java.net.UnknownHostException
protected void close()
public boolean isConnected()
protected void startRunner()
public static void main(java.lang.String[] args) throws java.io.IOException
java.io.IOException
Copyright © 1998-2009 Bela Ban / Red Hat. All Rights Reserved.