com.caucho.server.httpproxy

Class MessageQueueSubscription

java.lang.Object

com.caucho.server.httpproxy.MessageQueueSubscription

public class MessageQueueSubscription
extends java.lang.Object

System for messaging proxy

Method Summary

Modifier and Type	Method and Description
void	add(MessageStreamImpl2 item)
boolean	isAvailable()
void	offer(TempBuffer tbuf)
java.io.InputStream	readBinaryStream()
java.io.OutputStream	startBinaryStream()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

isAvailable

public boolean isAvailable()

add

public void add(MessageStreamImpl2 item)

startBinaryStream

public java.io.OutputStream startBinaryStream()

readBinaryStream

public java.io.InputStream readBinaryStream()

offer

public void offer(TempBuffer tbuf)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object