public class JDBCConsumer extends Object implements MessageConsumer
Constructor and Description |
---|
JDBCConsumer(JDBCMessageStore store)
Initialize consumer
|
Modifier and Type | Method and Description |
---|---|
boolean |
ack()
Ack on success message sending by processor
|
boolean |
cleanup()
Cleanup the consumer
|
String |
getId()
Get consumer id
|
boolean |
isAlive()
Check JDBC consumer is alive
|
MessageContext |
receive()
Select and return the first element in current table
|
void |
setId(int id)
Set consumer id
|
public JDBCConsumer(JDBCMessageStore store)
store
- - JDBC message storepublic MessageContext receive()
receive
in interface MessageConsumer
public boolean ack()
ack
in interface MessageConsumer
public boolean cleanup()
cleanup
in interface MessageConsumer
public boolean isAlive()
isAlive
in interface MessageConsumer
public void setId(int id)
setId
in interface MessageConsumer
id
- IDpublic String getId()
getId
in interface MessageConsumer
Copyright © 2005–2023 Apache Software Foundation. All rights reserved.