|
OSMQ v2.0.1 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectosmq.util.ExceptionListenerBase
osmq.util.ExceptionListenerImpl
osmq.net.SocketStreamFilter
Client stream for communicating with a remote service.
Constructor Summary | |
SocketStreamFilter(DiscoverySocket ds)
|
|
SocketStreamFilter(RemoteService es,
ExceptionListener listener)
|
|
SocketStreamFilter(java.net.Socket socket,
boolean binarymode)
|
Method Summary | |
void |
close()
|
void |
flush()
|
java.net.InetAddress |
getInetAddress()
|
long |
getWrittenCount()
Returns the number of message writes |
boolean |
isOpen()
|
void |
println(java.lang.String s)
Print a string to the socket stream |
void |
printlnCounted(java.lang.String s)
Print a string to the socket stream and increments the write count |
byte[] |
readBytes()
Reads the next byte array from the socket input stream. |
java.lang.String |
readln()
Reads the next String from the socket input stream. |
void |
setSocket(DiscoverySocket socket)
This method may be called to replace an exisiting socket. |
void |
setSocket(java.net.Socket socket,
boolean binarymode)
This method may be called to replace an exisiting socket. |
void |
writeBytes(byte[] v)
Write an array of bytes to the socket stream |
void |
writeBytesCounted(byte[] v)
Write an array of bytes to the socket stream and increments the write count |
void |
writeNull()
Used to test active socket connections. |
Methods inherited from class osmq.util.ExceptionListenerImpl |
onException |
Methods inherited from class osmq.util.ExceptionListenerBase |
getExceptionListener, setExceptionListener |
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public SocketStreamFilter(java.net.Socket socket, boolean binarymode) throws java.io.IOException
public SocketStreamFilter(DiscoverySocket ds) throws java.io.IOException
public SocketStreamFilter(RemoteService es, ExceptionListener listener) throws java.io.IOException
Method Detail |
public void setSocket(java.net.Socket socket, boolean binarymode) throws java.io.IOException
java.io.IOException
public void setSocket(DiscoverySocket socket) throws java.io.IOException
java.io.IOException
public long getWrittenCount()
public void printlnCounted(java.lang.String s) throws java.io.IOException
s
- the String to be printed
java.io.IOException
- if String size < 1 or there is a communications errorpublic void println(java.lang.String s) throws java.io.IOException
s
- the String to be printed
java.io.IOException
- if String size < 1 or there is a communications errorpublic void writeBytesCounted(byte[] v) throws java.io.IOException
v
- the bytes to be written
java.io.IOException
- if String size < 1 or there is a communications errorpublic void writeBytes(byte[] v) throws java.io.IOException
v
- the bytes to be written
java.io.IOException
- if String size < 1 or there is a communications errorpublic void writeNull() throws java.io.IOException
java.io.IOException
public java.lang.String readln() throws java.io.IOException
Note that the function ignores null length Strings.
java.io.IOException
- if there is a communications failure.public byte[] readBytes() throws java.io.IOException
Note that the function ignores null array.
java.io.IOException
- if there is a communications failure.public java.net.InetAddress getInetAddress()
public boolean isOpen()
public void flush() throws java.io.IOException
java.io.IOException
public void close()
|
(c) 2000 - 2003 MQue Systems All Rights Reserved |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |