brettlangdon
/
flume-hornetq
mirror of https://github.com/brettlangdon/flume-hornetq.git
1
0
Fork 0
Code Issues 0 Projects 0 Releases 0 Wiki Activity
HornetQ Sink plugin for Flume.
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
8 Commits
1 Branch
24 KiB
 
Branch: master
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'master'
${ noResults }
 ZIP  TAR.GZ
Brett Langdon 1c844d9cd3 Added MIT License 14 years ago
src/com/blangdon/flume/hornetq ensured that flume events were being properly converted to strings before sending to hornet 14 years ago
.gitignore Update master 14 years ago
LICENSE Added MIT License 14 years ago
README.md Rewrote README.md to include project overview, installation and HornetQJMSSink definition and example. 14 years ago
build.xml initial commit and prototype, testing 14 years ago

README.md

Flume HornetQ Plugin

Overview

This plugin has been built for and tested with Cloudera's Flume v0.9.4 from CDH3 in order to provide interoperability with HornetQ Messaging queue.

Install

  • In order to install you will need to place the HornetQ jars from the lib directory of the download package into the Flume lib directory: cp ./hornetq-2.2.14.Final/lib/*.jar /usr/lib/flume/lib/.
  • Download source: git clone git://github.com/brettlangdon/flume-hornetq.git
  • Build plugin: cd ./flume-hornetq then ant
  • Place flume-hornetq.jar into Flume lib directory: cp flume-hornetq.jar /usr/lib/flume/lib.
  • Add com.blangdon.flume.hornetq.HornetQJMSSink to the flume.plugin.classes property in your Flume site config: /etc/flume/cponf/flume-site/xml.

HornetQJMSSink

Provides a producer to send events to HornetQ

Definition

hornetQJMSSink( queueName, [jnpHost, jnpPort] )

Example

collector: autoCollectorSource() | hornetQJMSSink("/queue/name");

TODO

  • Auto Reconnect, right now if there is a disconnect between Flume and HornetQ then no more events will be Produced.