public class MeetupRsvpStream
extends Object

Fields
Modifier and Type	Field	Description
`protected org.glassfish.tyrus.client.ClientManager`	`_client`
`protected boolean`	`_keepPublishing`
`protected boolean`	`_partitionByKey`
`protected org.apache.pinot.spi.stream.StreamDataProducer`	`_producer`
`protected static org.slf4j.Logger`	`LOGGER`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected javax.websocket.MessageHandler.Whole<String>`	`getMessageHandler()`
`void`	`run()`
`void`	`stopPublishing()`

protected static final org.slf4j.Logger LOGGER

protected final boolean _partitionByKey

protected final org.apache.pinot.spi.stream.StreamDataProducer _producer

protected org.glassfish.tyrus.client.ClientManager _client

protected volatile boolean _keepPublishing

public MeetupRsvpStream()
                 throws Exception

public MeetupRsvpStream(boolean partitionByKey)
                 throws Exception

public void run()
         throws Exception

protected javax.websocket.MessageHandler.Whole<String> getMessageHandler()

Constructor	Description
`MeetupRsvpStream()`
`MeetupRsvpStream(boolean partitionByKey)`

Class MeetupRsvpStream