package org.jboss.mq.il.oil2;
import java.io.IOException;
import org.jboss.mq.ReceiveRequest;
import org.jboss.mq.SpyDestination;
import org.jboss.mq.il.ClientIL;
public final class OIL2ClientIL
implements ClientIL,
java.io.Serializable
{
static final long serialVersionUID = -2671278802714517625L;
transient OIL2ServerILService.RequestListner requestListner;
transient OIL2SocketHandler socketHandler;
public void setRequestListner(OIL2ServerILService.RequestListner requestListner)
{
this.requestListner = requestListner;
this.socketHandler = requestListner.getSocketHandler();
}
public void close()
throws Exception
{
try {
OIL2Request request = new OIL2Request(
OIL2Constants.CLIENT_CLOSE,
null);
OIL2Response response = socketHandler.synchRequest(request);
response.evalThrowsException();
} catch ( IOException ignore ) {
}
requestListner.close();
}
public void deleteTemporaryDestination(SpyDestination dest)
throws Exception
{
OIL2Request request = new OIL2Request(
OIL2Constants.CLIENT_DELETE_TEMPORARY_DESTINATION,
new Object[] {dest});
OIL2Response response = socketHandler.synchRequest(request);
response.evalThrowsException();
}
public void pong(long serverTime)
throws Exception
{
OIL2Request request = new OIL2Request(
OIL2Constants.CLIENT_PONG,
new Object[] {new Long(serverTime)});
OIL2Response response = socketHandler.synchRequest(request);
response.evalThrowsException();
}
public void receive(ReceiveRequest messages[])
throws Exception
{
OIL2Request request = new OIL2Request(
OIL2Constants.CLIENT_RECEIVE,
new Object[] {messages});
OIL2Response response = socketHandler.synchRequest(request);
response.evalThrowsException();
}
}