|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.contrib.dbwriter.SqlInfoStreamPublisher
public class SqlInfoStreamPublisher
Field Summary | |
---|---|
private java.io.BufferedReader |
br
|
private boolean |
continuous
|
private int |
count
|
private static java.lang.String |
DATE
|
private static java.lang.String |
DATE_ALL
|
private static java.lang.String |
DATE_HR
|
private static java.lang.String |
DATE_MILLI
|
private static java.lang.String |
DATE_MIN
|
private static java.lang.String |
DATE_SEC
|
protected I_Update |
eventHandler
|
private java.lang.String |
filename
|
private Global |
glob
|
private boolean |
immediate
|
private static java.lang.String |
IMMEDIATE_TXT
|
private I_Info |
info
|
private static java.lang.String |
INPUT_FILENAME_TXT
|
private boolean |
isInitialized
|
private static java.util.logging.Logger |
log
|
private static java.lang.String |
MIN_DELAY_TXT
|
private long |
minDelay
|
private long |
nextTime
|
private long |
offsetTime
|
private long |
referenceMidnite
|
private SqlInfoParser |
sqlInfoParser
|
private java.lang.String |
startTime
|
private boolean |
stopped
|
private java.lang.String |
TAG
|
private long |
thisMidnite
|
private Timeout |
timeout
|
Constructor Summary | |
---|---|
SqlInfoStreamPublisher()
|
Method Summary | |
---|---|
private long |
calculateMidnite(long time)
|
private long |
calculateNewTime(long time)
|
private java.io.BufferedReader |
getBufferedReader(java.io.BufferedReader br,
java.lang.String filename)
|
private java.lang.String |
getContent(int pos,
java.lang.String origLine,
java.lang.String endTag)
|
XBSession |
getJmsSession()
Only used in replication, can return null if not used. |
private static long |
getStartTime(java.lang.String txt)
|
java.util.Set |
getUsedPropertyKeys()
Gets all property keys which may be used by this object. |
void |
init(I_Info info_)
After creation this method is called. |
static void |
main(java.lang.String[] args)
|
void |
parse()
|
private void |
processComment(int pos,
java.lang.String line,
java.lang.String endTag)
|
java.lang.String |
publish(java.lang.String changeKey,
byte[] message,
java.util.Map attrMap)
Send the message to the MoM. |
boolean |
registerAlertListener(I_Update update,
java.util.Map attrs)
Register for alerts when the data source has changed. |
void |
shutdown()
Cleanup resources. |
private void |
startTimeout()
|
void |
timeout(java.lang.Object userData)
You will be notified about the timeout through this method. |
private static java.util.Date |
txtToDate(java.lang.String dateTxt,
java.lang.String formatTxt)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private static final java.util.logging.Logger log
private static final java.lang.String DATE
private static final java.lang.String DATE_HR
private static final java.lang.String DATE_MIN
private static final java.lang.String DATE_SEC
private static final java.lang.String DATE_MILLI
private static final java.lang.String DATE_ALL
private java.lang.String TAG
private static final java.lang.String INPUT_FILENAME_TXT
private static final java.lang.String IMMEDIATE_TXT
private static final java.lang.String MIN_DELAY_TXT
private long nextTime
private long referenceMidnite
private long thisMidnite
private java.lang.String filename
private boolean immediate
protected I_Update eventHandler
private I_Info info
private boolean stopped
private Global glob
private java.io.BufferedReader br
private SqlInfoParser sqlInfoParser
private Timeout timeout
private long minDelay
private boolean isInitialized
private int count
private boolean continuous
private long offsetTime
private java.lang.String startTime
Constructor Detail |
---|
public SqlInfoStreamPublisher()
Method Detail |
---|
private static java.util.Date txtToDate(java.lang.String dateTxt, java.lang.String formatTxt)
private static long getStartTime(java.lang.String txt)
public void parse() throws java.lang.Exception
java.lang.Exception
private java.lang.String getContent(int pos, java.lang.String origLine, java.lang.String endTag) throws java.lang.Exception
java.lang.Exception
private void processComment(int pos, java.lang.String line, java.lang.String endTag) throws java.lang.Exception
java.lang.Exception
private long calculateMidnite(long time)
private long calculateNewTime(long time)
public XBSession getJmsSession()
I_ChangePublisher
getJmsSession
in interface I_ChangePublisher
public void init(I_Info info_) throws java.lang.Exception
I_ChangePublisher
init
in interface I_ChangePublisher
init
in interface I_ContribPlugin
info_
- The configuration environment
java.lang.Exception
- MoM specificprivate java.io.BufferedReader getBufferedReader(java.io.BufferedReader br, java.lang.String filename)
public java.lang.String publish(java.lang.String changeKey, byte[] message, java.util.Map attrMap) throws java.lang.Exception
I_ChangePublisher
publish
in interface I_ChangePublisher
changeKey
- Can be used to create the topic namemessage
- The message content to sendattrMap
- An optional map with attributes or null
java.lang.Exception
- On sending problemspublic boolean registerAlertListener(I_Update update, java.util.Map attrs) throws java.lang.Exception
I_ChangePublisher
This funtionality is plugin depending, for example the xmlBlaster plugin has a configuration option to subscribe on a alert topic and listens if somebody publishes a message to it. If such a message arrives we trigger a new database poll.
registerAlertListener
in interface I_ChangePublisher
update
- The callback interface to receive the notificationattrs
- extra parameters to pass for the registration. For example
if one implementation wants to do a specific extra subscription it would
pass the quality of service in the attributes.
java.lang.Exception
- The MoM specific exceptionprivate void startTimeout()
public void shutdown()
I_ChangePublisher
Can be called multiple times if instance is reused from different plugins.
shutdown
in interface I_ChangePublisher
shutdown
in interface I_ContribPlugin
I_Plugin
public java.util.Set getUsedPropertyKeys()
I_ContribPlugin
getUsedPropertyKeys
in interface I_ContribPlugin
public void timeout(java.lang.Object userData)
I_Timeout
timeout
in interface I_Timeout
userData
- You get bounced back your userData which you passed
with Timeout.addTimeoutListener()public static void main(java.lang.String[] args)
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |