public class StreamJunction.Publisher extends Object implements InputProcessor
Constructor and Description |
---|
Publisher() |
Modifier and Type | Method and Description |
---|---|
String |
getStreamId() |
void |
send(ComplexEvent complexEvent) |
void |
send(Event[] events,
int streamIndex) |
void |
send(Event event,
int streamIndex) |
void |
send(List<Event> events,
int streamIndex) |
void |
send(long timeStamp,
Object[] data,
int streamIndex) |
void |
setStreamJunction(StreamJunction streamJunction) |
public void setStreamJunction(StreamJunction streamJunction)
public void send(ComplexEvent complexEvent)
public void send(Event event, int streamIndex)
send
in interface InputProcessor
public void send(Event[] events, int streamIndex)
send
in interface InputProcessor
public void send(List<Event> events, int streamIndex)
send
in interface InputProcessor
public void send(long timeStamp, Object[] data, int streamIndex)
send
in interface InputProcessor
public String getStreamId()
Copyright © 2019. All rights reserved.