org.thales.punch.netty.relp.proto

Class RELPClient

java.lang.Object

org.thales.punch.netty.relp.proto.RELPClient

public class RELPClient
extends Object

As simple Relp client. Useful for injection tools or tests.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
RELPClient(String host, int port) Ctor

Method Summary

Modifier and Type	Method and Description
RELPClient	close() Close this client.
void	flush()
RELPClient	open() Open the client, this triggers the relp open acknowledgment
int	send(long txnr, byte[] data) Send a byte array payload
int	send(long txnr, String data) Send a string payload
RELPClient	setCallback(IRELPClientCallback cb)

Methods inherited from class java.lang.Object

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

Constructor Detail

RELPClient

public RELPClient(String host,
                  int port)

Ctor

Parameters:

host - the server host

port - the server port

Method Detail

setCallback

public RELPClient setCallback(IRELPClientCallback cb)

Parameters:

cb - the user callback

Returns:

this client

open

public RELPClient open()
                throws UnknownHostException,
                       IOException

Open the client, this triggers the relp open acknowledgment

Returns:

this client

Throws:

UnknownHostException - in case of pb

IOException - in case of pb

close

public RELPClient close()

Close this client. This sends the end of session to the server and waits for the connection to be closed properly.

Returns:

this client

send

public int send(long txnr,
                String data)

Send a string payload

Parameters:

txnr - the relp transaction number

data - the data as a string

Returns:

0 for success

send

public int send(long txnr,
                byte[] data)

Send a byte array payload

Parameters:

txnr - the relp transaction number

data - the data

Returns:

this client

flush

public void flush()