We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/activepieces/activepieces'
If you have feedback or need assistance with the MCP directory API, please join our Discord server
import { PiecePropValueSchema } from '@activepieces/pieces-framework';
import { rabbitmqAuth } from '../..';
import amqp, { Connection } from 'amqplib';
export async function rabbitmqConnect(
auth: PiecePropValueSchema<typeof rabbitmqAuth>,
): Promise<Connection> {
return amqp.connect(createAmqpURI(auth), (err: Error, conn: Connection) => {
if (err) {
throw err;
}
return conn;
});
}
function createAmqpURI(auth: PiecePropValueSchema<typeof rabbitmqAuth>): string {
const uri = `amqp://${auth.username}:${auth.password}@${auth.host}:${auth.port}`;
if (!auth.vhost) {
return uri;
}
return `${uri}/${auth.vhost}`;
}