BitfinexActor.xtend

@FinalFieldsConstructor static class BitfinexActor extends AbstractActor {

		extension val ActorHelper helper = new ActorHelper(this)
		val bitfinex = new AtomicReference<BitfinexWebsocketClient>()

		val String symbol

		override preStart() throws Exception {
			connect()
		}

		override createReceive() {
			throw new UnsupportedOperationException("TODO: auto-generated method stub")
		}

		@Subscribe def void onSubscribed(OnSubscribed onSubscribed) {
			info("Subscribed to " + onSubscribed.response)
		}

		@Subscribe def void onDisconnected(OnDisconnected onDisconnected) {
			error("Disconnected from bitfinex. Reconecting...")
			connect()
		}
		
		def void connect() {
			info("Connecting to bitfinex")
			bitfinex.set(new BitfinexWebsocketClient())
			bitfinex.get() => [
				eventBus.register(this)
				connectBlocking()
				send(new SubscribeTrades(symbol))
			]
		}

	}