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

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	StompConnection.Listener

Field Summary

Fields

Modifier and Type	Field	Description
protected DataInputStream	in
protected final Set<StompConnection.Listener>	listeners
protected final Log	log
protected DataOutputStream	out
protected Thread	runner
protected boolean	running
protected final Set<String>	server_destinations
protected String	session_id
protected Socket	sock
protected final Set<String>	subscriptions

Constructor Summary

Constructors

Constructor	Description
StompConnection(String dest)

Method Summary

Modifier and Type	Method	Description
void	addListener(StompConnection.Listener listener)
protected void	close()
void	connect()
protected void	connect(String dest)
void	connect(String userid, String password)
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)
protected static SocketAddress	parse(String dest)
protected String	pickRandomDestination()
void	reconnect()
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	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

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

runner

protected Thread runner

running

protected volatile boolean running

session_id

protected String session_id

log

protected final Log log

Constructor Details

StompConnection

public StompConnection(String dest)

Parameters:

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

Method Details

getSessionId

public String getSessionId()

addListener

public void addListener(StompConnection.Listener listener)

removeListener

public void removeListener(StompConnection.Listener listener)

connect

public void connect(String userid,
 String password)
             throws IOException

Throws:

IOException

reconnect

public void reconnect()
               throws IOException

Throws:

IOException

connect

public void connect()
             throws IOException

Throws:

IOException

disconnect

public void disconnect()

subscribe

public void subscribe(String destination)

unsubscribe

public void unsubscribe(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)

pickRandomDestination

protected String pickRandomDestination()

connect

protected void connect(String dest)
                throws IOException

Throws:

IOException

parse

protected static SocketAddress parse(String dest)
                              throws UnknownHostException

Throws:

UnknownHostException

close

protected void close()

isConnected

public boolean isConnected()

startRunner

protected void startRunner()

main

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

Throws:

IOException