Package com.predic8.membrane.core.transport.http

Class StreamPump

java.lang.Object

com.predic8.membrane.core.transport.http.StreamPump

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

WebSocketStreamPump

public class StreamPump
extends Object
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamPump.StreamPumpStats

Field Summary

Fields

Modifier and Type	Field	Description
protected AtomicLong	bytesTransferred
protected final InputStream	in
protected static org.slf4j.Logger	log
protected final OutputStream	out
protected StreamPump.StreamPumpStats	stats

Constructor Summary

Constructors

Constructor	Description
StreamPump(InputStream in, OutputStream out, StreamPump.StreamPumpStats stats, String name, Rule rule)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getCreationTime()
String	getName()
String	getServiceProxyName()
long	getTransferredBytes()
void	run()

Methods inherited from class java.lang.Object

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

Field Details

log

protected static org.slf4j.Logger log

in

protected final InputStream in

out

protected final OutputStream out

stats

protected StreamPump.StreamPumpStats stats

bytesTransferred

protected AtomicLong bytesTransferred

Constructor Details

StreamPump

public StreamPump(InputStream in,
 OutputStream out,
 StreamPump.StreamPumpStats stats,
 String name,
 Rule rule)

Method Details

run

public void run()

Specified by:

run in interface Runnable

getName

public String getName()

getServiceProxyName

public String getServiceProxyName()

getTransferredBytes

public long getTransferredBytes()

getCreationTime

public long getCreationTime()

close

public void close()