converted amqp input into transport

add some todos