co.cask.cdap.test.internal

Class DefaultStreamManager

java.lang.Object

co.cask.cdap.test.internal.DefaultStreamManager

All Implemented Interfaces:

StreamManager

public class DefaultStreamManager
extends Object
implements StreamManager

Default implementation of StreamManager for use in tests

Constructor Summary

Constructors

Constructor and Description
DefaultStreamManager(co.cask.cdap.data.stream.service.StreamHandler streamHandler, co.cask.cdap.data.stream.service.StreamFetchHandler streamFetchHandler, co.cask.cdap.proto.Id.Stream streamId)

Method Summary

Methods

Modifier and Type	Method and Description
void	createStream()
protected void	finalize()
List<StreamEvent>	getEvents(long startTime, long endTime, int limit)
List<StreamEvent>	getEvents(String startTime, String endTime, int limit)
void	send(byte[] content)
void	send(byte[] content, int off, int len)
void	send(ByteBuffer buffer)
void	send(File file, String contentType)
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

DefaultStreamManager

@Inject
public DefaultStreamManager(co.cask.cdap.data.stream.service.StreamHandler streamHandler,
                           co.cask.cdap.data.stream.service.StreamFetchHandler streamFetchHandler,
                           co.cask.cdap.proto.Id.Stream streamId)

Method Detail

createStream

public void createStream()
                  throws IOException

Specified by:

createStream in interface StreamManager

Throws:

IOException

send

public void send(String content)
          throws IOException

Specified by:

send in interface StreamManager

Throws:

IOException

send

public void send(byte[] content)
          throws IOException

Specified by:

send in interface StreamManager

Throws:

IOException

send

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

Specified by:

send in interface StreamManager

Throws:

IOException

send

public void send(ByteBuffer buffer)
          throws IOException

Specified by:

send in interface StreamManager

Throws:

IOException

send

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

Specified by:

send in interface StreamManager

Throws:

IOException

send

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

Specified by:

send in interface StreamManager

Throws:

IOException

send

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

Specified by:

send in interface StreamManager

Throws:

IOException

send

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

Specified by:

send in interface StreamManager

Throws:

IOException

send

public void send(File file,
        String contentType)
          throws Exception

Specified by:

send in interface StreamManager

Throws:

Exception

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

getEvents

public List<StreamEvent> getEvents(String startTime,
                          String endTime,
                          int limit)
                            throws IOException

Specified by:

getEvents in interface StreamManager

Throws:

IOException

getEvents

public List<StreamEvent> getEvents(long startTime,
                          long endTime,
                          int limit)
                            throws IOException

Specified by:

getEvents in interface StreamManager

Throws:

IOException