9 Replies Latest reply on Sep 26, 2012 9:26 PM by Clebert Suconic

    HornetQ read or export journal files and archive them

    Hitz Jain Newbie

      I am working on the hornetQ ESB for an Integration project but then unable to find process to export the jms messages recevied onto clear text.

      I would also be interested in knowing the process to delete/archive the journal files without missing any message.

       

      Env:

      Windows 7

      JBoss SOA 5.3 GA

      JBoss ESB 4.11

      HornetQ Server version 2.2.10.GA

       

      When running the export using the process provided in the hornetQ documentation

                                   java -cp hornetq-core.jar org.hornetq.core.journal.impl.ExportJournal <JournalDirectory> <JournalPrefix> <FileExtension> <FileSize> <FileOutput>

       

      I get the response as below

       

      #File,JournalFileImpl: (hornetq-data-1.hq id = 1, recordID = 1)

      operation@AddRecord,id@231,userRecordType@31,length@226,isUpdate@false,compactCount@0,data@AAAAiQAAAHSs7QAFdABtPHVzZXIgdmVyc2lvbj0iMSI-PHVzZXJJZD5oamFpbjE8L3VzZXJJZD48dXNlck5hbWU-SGl0ZXNoPC91c2VyTmFtZT48dXNlclBhc3N3b3JkPjEyMzQ8L3VzZXJQYXNzd29yZD48L3VzZXI-MAAAAO8AAAAAAAAA5wEAAAAwagBtAHMALgBxAHUAZQB1AGUALgBkAGUAcgBlAGcAUgBlAHEAdQBlAHMAdABHAFcAASDgtFX3ihHhi1kAIWqo29oC_wAAAAAAAAAAAAABOZfCFUkEAA==

      operation@Update,id@231,userRecordType@32,length@8,isUpdate@true,compactCount@0,data@AAAAAAAAAAA=

      operation@AddRecord,id@232,userRecordType@31,length@372,isUpdate@false,compactCount@0,data@AAAAigAAAHWs7QAFdABuPHVzZXIgdmVyc2lvbj0iMSI-PHVzZXJJZD5oamFpbjE8L3VzZXJJZD48dXNlck5hbWU-SGl0ZXNoPC91c2VyTmFtZT48dXNlclBhc3N3b3JkPjEyMzQ8L3VzZXJQYXNzd29yZD48L3VzZXI-MDEAAAGBAAAAAAAAAOgBAAAAMGoAbQBzAC4AcQB1AGUAdQBlAC4AZABlAHIAZQBnAFIAZQBxAHUAZQBzAHQARwBXAAEg7E0W94oR4YtZACFqqNvaAv8AAAAAAAAAAAAAATmXwhWVBAEAAAABAAAAfF8ASABRAF8AUgBPAFUAVABFAF8AVABPAHMAZgAuAG0AeQAtAGMAbAB1AHMAdABlAHIALgBkADMAMwBjADkAYgAyAGMALQBmADcAOAA5AC0AMQAxAGUAMQAtAGIAMgA4ADYALQA1ADUAMABjAGUANAA1AGUAOAAxADEANQAEAAAACAAAAAAAAAAA

      operation@Update,id@232,userRecordType@32,length@8,isUpdate@true,compactCount@0,data@AAAAAAAAAEo=

      operation@Update,id@231,userRecordType@33,length@8,isUpdate@true,compactCount@0,data@AAAAAAAAAAA=

      operation@DeleteRecord,id@231

      operation@Update,id@232,userRecordType@33,length@8,isUpdate@true,compactCount@0,data@AAAAAAAAAEo=

      operation@DeleteRecord,id@232

      operation@AddRecord,id@233,userRecordType@31,length@228,isUpdate@false,compactCount@0,data@AAAAiwAAAHas7QAFdABvPHVzZXIgdmVyc2lvbj0iMSI-PHVzZXJJZD5oamFpbjE8L3VzZXJJZD48dXNlck5hbWU-SGl0ZXNoPC91c2VyTmFtZT48dXNlclBhc3N3b3JkPjEyMzQ8L3VzZXJQYXNzd29yZD48L3VzZXI-MDEyAAAA8QAAAAAAAADpAQAAADBqAG0AcwAuAHEAdQBlAHUAZQAuAGQAZQByAGUAZwBSAGUAcQB1AGUAcwB0AEcAVwABIQay5_eKEeGLWQAhaqjb2gL_AAAAAAAAAAAAAAE5l8IWQgQA

      operation@Update,id@233,userRecordType@32,length@8,isUpdate@true,compactCount@0,data@AAAAAAAAAAA=

      operation@Update,id@233,userRecordType@33,length@8,isUpdate@true,compactCount@0,data@AAAAAAAAAAA=

      operation@DeleteRecord,id@233

       

       

      This really doesn't help me understand what has happened to the request and also I am unable to decode the actual message that was transmitted across via the JMS provider.

      As per the HornetQ documentation it says you would be able to get the message in clear text but I don't see the same happening. Has anyone got to the point of getting a clear text message.

       

      My purpose of the above is for monitoring the # of messages that came in via the hornetQ server and really got processed and are pending processing. I know HornetQ takes care of reprocessing the pending messages but I want to have a little more flexibility to drop the request message on the queue for reprocessing, in case the biz decides to reprocess it.

       

      Also I read a lot of issues related to archiving the old files - would we know how this works? Since I see cross-references among the journal files which means we really cannot delete the files AS-IS.

       

      Any inputs would help...