Package org.jgroups.client

Class StompConnection

java.lang.Object

org.jgroups.client.StompConnection

All Implemented Interfaces:

Runnable

public class StompConnection
extends Object
implements Runnable

STOMP client to access the STOMP [1] protocol. Note that the full STOMP protocol is not implemented, e.g. transactions are currently not supported.

The interactive client can be started with -h HOST -p PORT, which are the hostname and port of a JGroups server, running with STOMP in its stack configuration. The interactive client supports automatic failover to a different server if the currently connected-to server crashes, and a simple syntax for sending STOMP messages:

 subscribe DEST // example: subscribe /topics/a
 send DEST message // example: send /topics/a Hello world
 

[1] http://stomp.codehaus.org/Protocol

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	StompConnection.ConnectionCallback
static interface	StompConnection.Listener

Field Summary

Fields

Modifier and Type	Field	Description
protected final Set<StompConnection.ConnectionCallback>	callbacks
protected DataInputStream	in
protected final Set<StompConnection.Listener>	listeners
protected final Log	log
protected DataOutputStream	out
protected String	password
protected boolean	reconnect
protected Thread	runner
protected boolean	running
protected final Set<String>	server_destinations
protected String	session_id
protected Socket	sock
protected SocketFactory	socket_factory
protected SSLParameters	sslParameters
protected final Set<String>	subscriptions
protected String	userid

Constructor Summary

Constructors

Constructor	Description
StompConnection(String dest)
StompConnection(String dest, boolean reconnect, boolean ssl)
StompConnection(String dest, boolean reconnect, SSLContext ssl)
StompConnection(String dest, String userid, String password, boolean reconnect, boolean ssl)
StompConnection(String dest, String userid, String password, boolean reconnect, SSLContext sslcontext)
StompConnection(String dest, String userid, String password, boolean reconnect, SSLContext sslcontext, SSLParameters sslParameters)

Method Summary

Modifier and Type	Method	Description
void	addCallback(StompConnection.ConnectionCallback cb)
void	addListener(StompConnection.Listener listener)
protected Socket	buildSocket(String host, int port)
protected void	closeConnections()
void	connect()
protected void	connectToDestination(String dest)
void	connectToSingleDestination(String destination)
void	disconnect()
String	getSessionId()
boolean	isConnected()
static void	main(String[] args)
protected void	notifyListeners(Map<String,String> info)
protected void	notifyListeners(Map<String,String> headers, byte[] buf, int offset, int length)
void	removeCallback(StompConnection.ConnectionCallback cb)
void	removeListener(StompConnection.Listener listener)
void	run()
void	send(String destination, byte[] buf)
void	send(String destination, byte[] buf, int offset, int length)
void	send(String destination, byte[] buf, int offset, int length, String... headers)
void	send(String destination, String... headers)	Sends an INFO without body
protected void	sendConnect()
protected void	sendSubscribe(String destination)
protected void	sendUnsubscribe(String destination)
void	startReconnectingClient()
protected void	startRunner()
void	subscribe(String destination)
void	unsubscribe(String destination)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

socket_factory

protected SocketFactory socket_factory

sock

protected Socket sock

in

protected DataInputStream in

out

protected DataOutputStream out

server_destinations

protected final Set<String> server_destinations

listeners

protected final Set<StompConnection.Listener> listeners

subscriptions

protected final Set<String> subscriptions

callbacks

protected final Set<StompConnection.ConnectionCallback> callbacks

runner

protected Thread runner

running

protected volatile boolean running

session_id

protected String session_id

userid

protected String userid

password

protected String password

reconnect

protected boolean reconnect

log

protected final Log log

sslParameters

protected SSLParameters sslParameters

Constructor Details

StompConnection

public StompConnection(String dest)

Parameters:

dest - IP address + ':' + port, e.g. "192.168.1.5:8787"

StompConnection

public StompConnection(String dest,
 boolean reconnect,
 boolean ssl)

StompConnection

public StompConnection(String dest,
 boolean reconnect,
 SSLContext ssl)

StompConnection

public StompConnection(String dest,
 String userid,
 String password,
 boolean reconnect,
 boolean ssl)

StompConnection

public StompConnection(String dest,
 String userid,
 String password,
 boolean reconnect,
 SSLContext sslcontext)

StompConnection

public StompConnection(String dest,
 String userid,
 String password,
 boolean reconnect,
 SSLContext sslcontext,
 SSLParameters sslParameters)

Method Details

getSessionId

public String getSessionId()

addListener

public void addListener(StompConnection.Listener listener)

addCallback

public void addCallback(StompConnection.ConnectionCallback cb)

removeListener

public void removeListener(StompConnection.Listener listener)

removeCallback

public void removeCallback(StompConnection.ConnectionCallback cb)

startRunner

protected void startRunner()

sendConnect

protected void sendConnect()
                    throws IOException

Throws:

IOException

subscribe

public void subscribe(String destination)

sendSubscribe

protected void sendSubscribe(String destination)

unsubscribe

public void unsubscribe(String destination)

sendUnsubscribe

protected void sendUnsubscribe(String destination)

send

public void send(String destination,
 byte[] buf,
 int offset,
 int length,
 String... headers)

send

public void send(String destination,
 String... headers)

Sends an INFO without body

send

public void send(String destination,
 byte[] buf,
 int offset,
 int length)

send

public void send(String destination,
 byte[] buf)

run

public void run()

Specified by:

run in interface Runnable

notifyListeners

protected void notifyListeners(Map<String,String> headers,
 byte[] buf,
 int offset,
 int length)

notifyListeners

protected void notifyListeners(Map<String,String> info)

connectToSingleDestination

public void connectToSingleDestination(String destination)
                                throws IOException

Throws:

IOException

connect

public void connect()
             throws IOException

Throws:

IOException

startReconnectingClient

public void startReconnectingClient()

buildSocket

protected Socket buildSocket(String host,
 int port)
                      throws IOException

Throws:

IOException

connectToDestination

protected void connectToDestination(String dest)
                             throws IOException

Throws:

IOException

disconnect

public void disconnect()

closeConnections

protected void closeConnections()

isConnected

public boolean isConnected()

main

public static void main(String[] args)
                 throws IOException

Throws:

IOException