// AMQP
// ====

#include "amqp_common.h"

Term amqp_close_run(Env e, Term* f, IoWork* w) {
  LapineConnection* lap = (LapineConnection*)(intptr_t)f[0];
  if (lap != NULL) {
    lapine_conn_free(lap);
  }
  return term_pak(CID_UNIT, 0);
}

static void __attribute__((constructor)) amqp_close_use(void) {
  io_eff(CID_AMQP_CLOSE, amqp_close_run, 0);
}