public class JDBCConsumer extends java.lang.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
|
java.lang.String |
getId()
Get consumer id
|
boolean |
isAlive()
Check JDBC consumer is alive
|
MessageContext |
receive()
Select and return the first element in current table
|
void |
setAlive(boolean isAlive)
Set isAlive flag in JDBC consumer
|
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 setAlive(boolean isAlive)
setAlive
in interface MessageConsumer
isAlive
- statuspublic void setId(int id)
setId
in interface MessageConsumer
id
- IDpublic java.lang.String getId()
getId
in interface MessageConsumer
Copyright © 2005-2021 Apache Software Foundation. All Rights Reserved.