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 and Description
static interface	StompConnection.Listener

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
StompConnection(String dest)
StompConnection(String dest, boolean reconnect, boolean ssl)
StompConnection(String dest, String userid, String password, boolean reconnect, boolean ssl)

Method Summary

Methods

Modifier and Type	Method and Description
void	addListener(StompConnection.Listener listener)
protected void	closeConnections()
void	connect()
protected void	connectToDestination(String dest)
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	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 Detail

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

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

Constructor Detail

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,
               String userid,
               String password,
               boolean reconnect,
               boolean ssl)

Method Detail

getSessionId

public String getSessionId()

addListener

public void addListener(StompConnection.Listener listener)

removeListener

public void removeListener(StompConnection.Listener listener)

startRunner

protected void startRunner()

sendConnect

protected void sendConnect()

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)

connect

public void connect()
             throws IOException

Throws:

IOException

startReconnectingClient

public void startReconnectingClient()

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