public class JDBCProducer extends Object implements MessageProducer
Constructor and Description |
---|
JDBCProducer(JDBCMessageStore store)
Initialize producer
|
Modifier and Type | Method and Description |
---|---|
boolean |
cleanup()
Cleanup the producer
|
String |
getId()
Get producer id
|
void |
setId(int id)
Set producer id
|
boolean |
storeMessage(MessageContext synCtx)
Add a message to the end of the table.
|
public JDBCProducer(JDBCMessageStore store)
store
- - JDBC message storepublic boolean storeMessage(MessageContext synCtx)
storeMessage
in interface MessageProducer
synCtx
- message to insertpublic boolean cleanup()
cleanup
in interface MessageProducer
public void setId(int id)
setId
in interface MessageProducer
id
- IDpublic String getId()
getId
in interface MessageProducer
Copyright © 2005–2019 Apache Software Foundation. All rights reserved.