Stefán Freyr Stefánsson
ade00e441f
Adding minor class-level JavaDoc.
2013-07-19 11:24:13 +00:00
Stefán Freyr Stefánsson
af97b44a6f
merging pull request from cheddar - jacksonifying the RabbitMQ connection and config.
2013-07-19 11:16:50 +00:00
cheddar
0edfbaffab
Errr, needed to make the ConnectionFactory a JacksonifiedConnectionFactory
2013-07-18 13:17:11 -07:00
cheddar
807a52f963
Another take on the configuration
2013-07-18 13:16:42 -07:00
Stefán Freyr Stefánsson
ae4132adba
Adding a test producer application.
2013-07-18 19:42:07 +00:00
Stefán Freyr Stefánsson
da658ac69a
Changes according to Eric's comments on the pull request.
...
- moved the RabbitMQ ConnectionFactory configuration to a method of its own to clean up the FirehoseFactory.connect() method.
- using Throwables.propagate*() methods in exception handling.
- removed TODOs and instead using the "keyword" FUTURE as well as adding some context to the comments themselves.
- cleaned up the exception handling in hasMore() a little and made it more readable.
2013-07-18 19:30:14 +00:00
Stefán Freyr Stefánsson
217d539e46
Adding a newline at the end of the file.
2013-07-16 15:18:03 +00:00
Stefán Freyr Stefánsson
22ec7c53fc
Code cleanup and formatting, documentation and moving all configuration into the consumerProps.
2013-07-16 15:08:39 +00:00
Stefán Freyr Stefánsson
d2f8e52752
Merge remote-tracking branch 'upstream/master' into rabbitmq
2013-07-16 13:08:10 +00:00
cheddar
dcc9942d8a
1) Update version of http-client
2013-07-15 14:19:05 -07:00
Stefán Freyr Stefánsson
a43ccf587f
Fixed some errors in the realtime.spec and query.body files and cleaned up the format to make it more readable as an example.
2013-07-15 18:38:21 +00:00
Stefán Freyr Stefánsson
82d2623cc9
Minor sanity checks when checking for and processing a new message.
2013-07-15 15:25:59 +00:00
Stefán Freyr Stefánsson
13328a6b36
Implemented a better query.body for the test I'm using. Added a shutdown listener to the connection and channel to get a notification when they are closed. Question remains whether the connection should be re-established when that happens.
2013-07-15 09:50:58 +00:00
Stefán Freyr Stefánsson
4d998e4c27
Making more things configurable through the realtime.spec file.
2013-07-13 16:49:39 +00:00
Stefán Freyr Stefánsson
fc74333a28
adding an example dir to test the rabbitmq implementation
2013-07-13 16:14:10 +00:00
Stefán Freyr Stefánsson
01b7507a5a
First version of a RabbitMQ Firehose implementation.
2013-07-13 16:03:46 +00:00
cheddar
09b1130810
Merge pull request #186 from rjurney/master
...
Made upload.sh executable
2013-07-11 13:06:58 -07:00
cheddar
33ac931b80
Merge pull request #185 from rjurney/test-harness
...
Fixed hanging ssh bug FINALLY
2013-07-11 13:06:02 -07:00
Russell Jurney
a33aa57ca9
Made webstream example work.
2013-07-10 17:04:51 -07:00
Russell Jurney
921bee33d9
Merge branch 'master' of github.com:metamx/druid
2013-07-10 14:19:35 -07:00
cheddar
c519be5b9f
1) Fix stray imports from libraries that aren't depended on and fix annotations/methods accordingly.
2013-07-10 14:19:04 -07:00
Russell Jurney
9d9d49f9b5
Make upload script executable
2013-07-10 14:17:40 -07:00
cheddar
3778425250
1) Fix new WebStreamFirehose stuff to have tests in the tests directory
...
2) Change the webStream package to the web package, because capital letters in packages suck
2013-07-10 14:12:13 -07:00
Russell Jurney
a39148a0af
Fixed hanging ssh bug FINALLY
2013-07-09 18:41:06 -07:00
cheddar
b83bc14784
Merge pull request #173 from metamx/dhruv
...
Add new demo firehose that is lower friction than twitter
2013-07-09 17:39:51 -07:00
Dhruv Parthasarathy
bd6dcd3973
interruption!
2013-07-09 17:39:19 -07:00
cheddar
093953c041
Merge pull request #170 from metamx/batch-zk
...
Enable batched ZK announcements
2013-07-09 17:23:47 -07:00
Dhruv Parthasarathy
ba484fca5c
catch error
2013-07-09 17:17:21 -07:00
fjy
dd203f969b
announcer thread fixes
2013-07-09 17:16:45 -07:00
Dhruv Parthasarathy
9f7284c801
fixed thread stuff
2013-07-09 16:59:49 -07:00
Dhruv Parthasarathy
b3157c2752
made thread final
2013-07-09 16:42:35 -07:00
Dhruv Parthasarathy
3250c698bb
fixed thread stuff and made tests cleaner
2013-07-09 16:34:55 -07:00
Dhruv Parthasarathy
6d000fc4c2
interfaces added and tests simplified
2013-07-09 15:31:03 -07:00
cheddar
e50bcf4309
Merge pull request #184 from rjurney/test-harness
...
Upload script for test-harness tarball
2013-07-09 15:18:46 -07:00
Russell Jurney
fa0d37f14e
Upload script for services tarball, relies on s3cmd
2013-07-09 15:10:44 -07:00
Russell Jurney
b2cb9bead4
Merge branch 'master' of github.com:metamx/druid into test-harness
2013-07-09 14:48:17 -07:00
Russell Jurney
6568728ead
Merge branch 'master' of github.com:rjurney/druid into test-harness
2013-07-09 14:48:06 -07:00
cheddar
2403056a0e
Merge pull request #183 from rjurney/test-harness
...
Scripts for firing up stuff and getting a stand-alone AWS node working
2013-07-09 14:47:43 -07:00
Russell Jurney
2df7463311
Removed dupe numThreads value from configs, fiddling with run_ec2.sh/env.sh
2013-07-09 14:44:03 -07:00
Dhruv Parthasarathy
41cb115d60
few more changes to RenamingKeysUpdateStreamFactory and test
2013-07-09 10:46:43 -07:00
Dhruv Parthasarathy
72fbc516bc
added a RenameKeysUpdateStream wrapper
2013-07-08 18:53:08 -07:00
Russell Jurney
570fb1cf19
Working stuff, doing pull request. CTRL-C problem remains.
2013-07-08 17:30:37 -07:00
Dhruv Parthasarathy
142271aad2
better encapsulation
2013-07-08 16:46:47 -07:00
Dhruv Parthasarathy
01b4728c40
removed shared queue structure. Queue now encapsulated within updateStream
2013-07-08 14:27:35 -07:00
Russell Jurney
2403f1eceb
Seperated env/run files.
2013-07-08 13:42:50 -07:00
Dhruv Parthasarathy
e7da31e42d
seems to be working
2013-07-08 13:41:19 -07:00
Dhruv Parthasarathy
439e8ca4ad
now take a map for renaming
2013-07-08 13:35:22 -07:00
Dhruv Parthasarathy
c8c686c738
added druid license comments
2013-07-08 12:19:38 -07:00
Dhruv Parthasarathy
adc00e6576
fixed with Erics suggestions
2013-07-08 12:13:25 -07:00
fjy
adda1488dc
another thread safety fix
2013-07-08 10:59:07 -07:00