issue with type: 'queue' in seneca transport

[robbdempsey]

Evaluating seneca-kafka-transport by running through the examples in the repo. We keep hitting the error below. Tried bumping to the latest version of seneca to no avail. It appears seneca-tranport is failing based on the action definition within the kafka transport.

seneca.add({role:'transport',hook:'listen',type:'queue'}, hookListenQueue);
seneca.add({role:'transport',hook:'client',type:'queue'}, hookClientQueue);

This is the line that is responding.
https://github.com/rjrodger/seneca-transport/blob/master/transport.js#L157

Is there a workaround for this? Any proposed fixes? Willing to help out if so.

steps

1. clone repo
2. step through examples of creating request/response topics
3. set config
4. node server.js

env

• node - 0.10.38
• kafka - 0.8.2.1
• zookeeper - 3.4.6_1

Seneca Fatal Error

Message: Seneca/0.5.21/3yg7c3tq7yj4/1437161526709/-: plugin-needed: [ 'plugin-needed', { name: 'seneca-beanstalkd-transport' } ]

Code: transport_listen

Stack:
at Seneca.fail (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/lib/seneca.js:1882:15)
at handle_legacy_types (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/node_modules/seneca-transport/transport.js:138:19)
at Seneca.cmd_listen (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/node_modules/seneca-transport/transport.js:107:9)
at Object.execspec.fn (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/lib/seneca.js:1442:24)
at Object._onImmediate (/Users/robb/sites/eLab Solutions/phelix/dev/seneca-kafka-transport/node_modules/seneca/lib/executor.js:93:14)
at processImmediate as _immediateCallback

Instance: Seneca/0.5.21/3yg7c3tq7yj4/1437161526709/-

When: 2015-07-17T19:32:07.092Z

Log: [sys,seneca,0.5.21,3yg7c3tq7yj4/1437161526709/-,transport_listen,Seneca/0.5.21/3yg7c3tq7yj4/1437161526709/-: plugin-needed: [ 'plugin-needed', { name: 'seneca-beanstalkd-transport' } ],[{type=queue,msgprefix=seneca_,callmax=111111,msgidlen=12}]]

Node: { http_parser: '1.0', node: '0.10.38', v8: '3.14.5.9', ares: '1.9.0-DEV', uv: '0.10.36', zlib: '1.2.8', modules: '11', openssl: '1.0.1m' }