ActiveMQ Journal ComponentThe ActiveMQ Journal Component allows messages to be stored in a rolling log file and then consumed from that log file. The journal aggregates and batches up concurrent writes so that to overhead of writing and waiting for the disk sync is relatively constant regardless of how many concurrent writes are being done. Therefore, this component supports and encourages you to use multiple concurrent producers to the same journal endpoint. Each journal endpoint uses a different log file and therefore write batching (and the associated performance boost) does not occur between multiple endpoints. This component only supports 1 active consumer on the endpoint. After the message is processed by the consumer's processor, the log file is marked and only subsequent messages in the log file will get delivered to consumers. URI formatactivemq.journal:directory-name[?options] So for example to send to the journal located in the /tmp/data directory you would use activemq.journal:/tmp/data Options
Expected Exchange Data TypesThe consumer of a Journal endpoint generates DefaultExchange
The producer to a Journal endpoint expects an Exchange See Also |
|
