incoming->is_incoming = GNUNET_YES;
incoming->peer = *source;
incoming->channel = channel;
- incoming->mq = GNUNET_CADET_mq_create (incoming->channel);
+ incoming->mq = GNUNET_CADET_get_mq (incoming->channel);
incoming->vt = &incoming_vt;
incoming->timeout_task
= GNUNET_SCHEDULER_add_delayed (INCOMING_CHANNEL_TIMEOUT,
&channel_window_cb,
&channel_end_cb,
cadet_handlers);
- op->mq = GNUNET_CADET_mq_create (op->channel);
+ op->mq = GNUNET_CADET_get_mq (op->channel);
set->vt->evaluate (op,
context);
GNUNET_SERVICE_client_continue (client);