All URIs are relative to http://mb1.bus.adaptive.me/rabbitmq/api
Method | HTTP request | Description |
---|---|---|
CreateExchange | PUT /exchanges/{vhost}/{exchange} | Create Exchange |
DeleteExchange | DELETE /exchanges/{vhost}/{exchange} | Delete Exchange |
GetExchange | GET /exchanges/{vhost}/{exchange} | Read Exchange |
ListExchanges | GET /exchanges | List Exchanges |
ListExchangesForHost | GET /exchanges/{vhost} | List Exchanges for VHost |
PublishMessage | POST /exchanges/{vhost}/{exchange}/publish | Publish Message |
void CreateExchange (string vhost, string exchange, ExchangeRequest body = null)
Create Exchange
using System;
using System.Diagnostics;
using Thinkcode.RabbitMQ.OpenAPI.Api;
using Thinkcode.RabbitMQ.OpenAPI.Client;
using Thinkcode.RabbitMQ.OpenAPI.Model;
namespace Example
{
public class CreateExchangeExample
{
public void main()
{
// Configure HTTP basic authorization: basic_auth
Configuration.Default.Username = "YOUR_USERNAME";
Configuration.Default.Password = "YOUR_PASSWORD";
var apiInstance = new ExchangesApi();
var vhost = vhost_example; // string |
var exchange = exchange_example; // string |
var body = new ExchangeRequest(); // ExchangeRequest | (optional)
try
{
// Create Exchange
apiInstance.CreateExchange(vhost, exchange, body);
}
catch (Exception e)
{
Debug.Print("Exception when calling ExchangesApi.CreateExchange: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
vhost | string | ||
exchange | string | ||
body | ExchangeRequest | [optional] |
void (empty response body)
- Content-Type: application/json
- Accept: Not defined
[Back to top] [Back to API list] [Back to Model list] [Back to README]
void DeleteExchange (string vhost, string exchange)
Delete Exchange
using System;
using System.Diagnostics;
using Thinkcode.RabbitMQ.OpenAPI.Api;
using Thinkcode.RabbitMQ.OpenAPI.Client;
using Thinkcode.RabbitMQ.OpenAPI.Model;
namespace Example
{
public class DeleteExchangeExample
{
public void main()
{
// Configure HTTP basic authorization: basic_auth
Configuration.Default.Username = "YOUR_USERNAME";
Configuration.Default.Password = "YOUR_PASSWORD";
var apiInstance = new ExchangesApi();
var vhost = vhost_example; // string |
var exchange = exchange_example; // string |
try
{
// Delete Exchange
apiInstance.DeleteExchange(vhost, exchange);
}
catch (Exception e)
{
Debug.Print("Exception when calling ExchangesApi.DeleteExchange: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
vhost | string | ||
exchange | string |
void (empty response body)
- Content-Type: Not defined
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
Exchange GetExchange (string vhost, string exchange)
Read Exchange
using System;
using System.Diagnostics;
using Thinkcode.RabbitMQ.OpenAPI.Api;
using Thinkcode.RabbitMQ.OpenAPI.Client;
using Thinkcode.RabbitMQ.OpenAPI.Model;
namespace Example
{
public class GetExchangeExample
{
public void main()
{
// Configure HTTP basic authorization: basic_auth
Configuration.Default.Username = "YOUR_USERNAME";
Configuration.Default.Password = "YOUR_PASSWORD";
var apiInstance = new ExchangesApi();
var vhost = vhost_example; // string |
var exchange = exchange_example; // string |
try
{
// Read Exchange
Exchange result = apiInstance.GetExchange(vhost, exchange);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ExchangesApi.GetExchange: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
vhost | string | ||
exchange | string |
- Content-Type: Not defined
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
List ListExchanges ()
List Exchanges
using System;
using System.Diagnostics;
using Thinkcode.RabbitMQ.OpenAPI.Api;
using Thinkcode.RabbitMQ.OpenAPI.Client;
using Thinkcode.RabbitMQ.OpenAPI.Model;
namespace Example
{
public class ListExchangesExample
{
public void main()
{
// Configure HTTP basic authorization: basic_auth
Configuration.Default.Username = "YOUR_USERNAME";
Configuration.Default.Password = "YOUR_PASSWORD";
var apiInstance = new ExchangesApi();
try
{
// List Exchanges
List<Exchange> result = apiInstance.ListExchanges();
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ExchangesApi.ListExchanges: " + e.Message );
}
}
}
}
This endpoint does not need any parameter.
- Content-Type: Not defined
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
List ListExchangesForHost (string vhost)
List Exchanges for VHost
using System;
using System.Diagnostics;
using Thinkcode.RabbitMQ.OpenAPI.Api;
using Thinkcode.RabbitMQ.OpenAPI.Client;
using Thinkcode.RabbitMQ.OpenAPI.Model;
namespace Example
{
public class ListExchangesForHostExample
{
public void main()
{
// Configure HTTP basic authorization: basic_auth
Configuration.Default.Username = "YOUR_USERNAME";
Configuration.Default.Password = "YOUR_PASSWORD";
var apiInstance = new ExchangesApi();
var vhost = vhost_example; // string |
try
{
// List Exchanges for VHost
List<Exchange> result = apiInstance.ListExchangesForHost(vhost);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ExchangesApi.ListExchangesForHost: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
vhost | string |
- Content-Type: Not defined
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
PublishResponse PublishMessage (string vhost, string exchange, PublishRequest body = null)
Publish Message
using System;
using System.Diagnostics;
using Thinkcode.RabbitMQ.OpenAPI.Api;
using Thinkcode.RabbitMQ.OpenAPI.Client;
using Thinkcode.RabbitMQ.OpenAPI.Model;
namespace Example
{
public class PublishMessageExample
{
public void main()
{
// Configure HTTP basic authorization: basic_auth
Configuration.Default.Username = "YOUR_USERNAME";
Configuration.Default.Password = "YOUR_PASSWORD";
var apiInstance = new ExchangesApi();
var vhost = vhost_example; // string |
var exchange = exchange_example; // string |
var body = new PublishRequest(); // PublishRequest | (optional)
try
{
// Publish Message
PublishResponse result = apiInstance.PublishMessage(vhost, exchange, body);
Debug.WriteLine(result);
}
catch (Exception e)
{
Debug.Print("Exception when calling ExchangesApi.PublishMessage: " + e.Message );
}
}
}
}
Name | Type | Description | Notes |
---|---|---|---|
vhost | string | ||
exchange | string | ||
body | PublishRequest | [optional] |
- Content-Type: application/json
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]