co.cask.cdap.test.internal
Class DefaultStreamWriter

java.lang.Object
  co.cask.cdap.test.internal.DefaultStreamWriter

All Implemented Interfaces:

StreamWriter

public final class DefaultStreamWriter
extends Object
implements StreamWriter

Constructor Summary

DefaultStreamWriter(co.cask.cdap.data.stream.service.StreamHandler streamHandler, co.cask.cdap.common.queue.QueueName streamName, String accountId)

Method Summary

void	createStream()
protected void	finalize()
void	send(byte[] content)
void	send(byte[] content, int off, int len)
void	send(ByteBuffer buffer)
void	send(Map<String,String> headers, byte[] content)
void	send(Map<String,String> headers, byte[] content, int off, int len)
void	send(Map<String,String> headers, ByteBuffer buffer)
void	send(Map<String,String> headers, String content)
void	send(String content)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultStreamWriter

@Inject
public DefaultStreamWriter(co.cask.cdap.data.stream.service.StreamHandler streamHandler,
                                  co.cask.cdap.common.queue.QueueName streamName,
                                  String accountId)
                    throws IOException

Throws:

IOException

Method Detail

createStream

public void createStream()
                  throws IOException

Specified by:

createStream in interface StreamWriter

Throws:

IOException

send

public void send(String content)
          throws IOException

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(byte[] content)
          throws IOException

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(byte[] content,
                 int off,
                 int len)
          throws IOException

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(ByteBuffer buffer)
          throws IOException

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(Map<String,String> headers,
                 String content)
          throws IOException

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(Map<String,String> headers,
                 byte[] content)
          throws IOException

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(Map<String,String> headers,
                 byte[] content,
                 int off,
                 int len)
          throws IOException

Specified by:

send in interface StreamWriter

Throws:

IOException

send

public void send(Map<String,String> headers,
                 ByteBuffer buffer)
          throws IOException

Specified by:

send in interface StreamWriter

Throws:

IOException

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable