cscotta/octobot

A distributed task queue worker designed for throughput, parallelism, and clustering.

octobot's Issues

is this project dead?

site down?

any chance the webiste will be back up? or is there another recommended library to accomplish something similar?

Queue metrics aren't available in introspector

I'm not sure if the best way to implement this, but what would be the recommended approach for getting the Metrics.MetricsRegistry exposed into the Introspector so that the queue metrics and be included in the JSON output?

Connection Shutdown issue

Getting this error repeatedly with octobot, connection with Rabbit MQ breaks.

Error in logs:

java.net.SocketException: Broken pipe
at java.net.SocketOutputStream.socketWrite0(Native Method)
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:65)
at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:123)
at java.io.DataOutputStream.flush(DataOutputStream.java:106)
at com.rabbitmq.client.impl.SocketFrameHandler.flush(SocketFrameHandler.java:142)
at com.rabbitmq.client.impl.AMQConnection.flush(AMQConnection.java:481)
at com.rabbitmq.client.impl.AMQCommand.transmit(AMQCommand.java:125)
at com.rabbitmq.client.impl.AMQChannel.quiescingTransmit(AMQChannel.java:316)
at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:292)
at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:285)
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:376)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:516)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533)
at com.urbanairship.octobot.RabbitMQ.getConnection(RabbitMQ.java:56)
at com.urbanairship.octobot.ChannelPool.initialize(ChannelPool.java:54)
at com.urbanairship.octobot.ChannelPool$ResetShutdownListener.shutdownCompleted(ChannelPool.java:41)
at com.rabbitmq.client.impl.ShutdownNotifierComponent.notifyListeners(ShutdownNotifierComponent.java:75)
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:548)
[AMQP Connection] ERROR ChannelPool  - Could not connect to RabbitMQ. Sleeping for 1 seconds.
com.rabbitmq.client.PossibleAuthenticationFailureException: Possibly caused by authentication failure
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:348)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:516)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:533)
at com.urbanairship.octobot.RabbitMQ.getConnection(RabbitMQ.java:56)
at com.urbanairship.octobot.ChannelPool.initialize(ChannelPool.java:54)
at com.urbanairship.octobot.ChannelPool$ResetShutdownListener.shutdownCompleted(ChannelPool.java:41)
at com.rabbitmq.client.impl.ShutdownNotifierComponent.notifyListeners(ShutdownNotifierComponent.java:75)
at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:548)
Caused by: com.rabbitmq.client.AlreadyClosedException: clean connection shutdown; reason: Attempt to use closed channel
at com.rabbitmq.client.impl.AMQChannel.ensureIsOpen(AMQChannel.java:190)
at com.rabbitmq.client.impl.AMQChannel.rpc(AMQChannel.java:223)
at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:209)
at com.rabbitmq.client.impl.AMQChannel.rpc(AMQChannel.java:202)
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:340)

Website is Down

Looks like octobot.taco.cat is down again.

Using Scala classes

I've got octobot all up and running, but I'm having a hard time getting it to load my tasks. Specifically, they're Scala classes... am I missing something? I've got them packaged up in a jar as described by the docs, but they don't seem to be getting picked up. Are there more steps involved if I want to use Scala tasks?