Styjun

Stolen MacBook should I worry about my data?

Why is 3/4 a simple meter while 6/8 is a compound meter?

Should I ask for a raise one month before the end of an internship?

Number of Fingers for a Math Oriented Race

Looking for a plural noun related to ‘fulcrum’ or ‘pivot’ that denotes multiple things as crucial to success

Why might one *not* want to use a capo?

Can a network vulnerability be exploited locally?

Why can't you say don't instead of won't?

Coupling two 15 Amp circuit breaker for 20 Amp

Is this position a forced win for Black after move 14?

Should I judge the efficacy of Samadhi based on the ethical qualities of the meditator?

Shall I fix cracks on bathtub and how to fix them?

Journal published a paper, ignoring my objections as a referee

Printing a list as "a, b, c." using Python

Why can't I identify major and minor chords?

Should I use the words "pyromancy" and "necromancy" even if they don't mean what people think they do?

Is it unusual for a math department not to have a mail/web server?

Why is there not a willingness from the world to step in between Pakistan and India?

Group riding etiquette

Why did Starhopper's exhaust plume become brighter just before landing?

In Endgame, wouldn't Stark have remembered Hulk busting out of the stairwell?

How do you say "half the time …, the other half …" in German?

Alternatives to Network Backup

STM32 cannot reach individual registers and pins as PIC

Unable to set connector as AMQP when connecting to ActiveMQ using MassTransit

ActiveMQ broker embedded into Grails app is not listening for external connectionsHow to connect a remote jms client to an embedded activemq broker in tomcat?Apache ActiveMQ browser can't connect to JMX consoleActiveMQ remote connections refused despite 0.0.0.0 in broker URLConnecting to remote activemq instance running on docker containerUnable to upgrade client from ActiveMQ 5.5.1 to ActiveMQ 5.10How to connect spring application on docker to a cluster of activemq on dockerConnecting to ActiveMQ Artemis Docker Container with Core APIUnable to access ActiveMQ using JMS based code and amqp 1.0Integration testing with Spring, ActiveMQ and Qpid

.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty margin-bottom:0;

1

Using MassTransit I'm trying to connect to ActiveMQ using AMQP connector. MassTransit is configured to connect using OpenWire connector to port 61616.

Created a local container for ActiveMq using the following command

docker run --rm -d -p 5672:5672 -p 8161:8161 rmohr/activemq:5.15.6-alpine

Now when trying to connect to MassTransit I am passing the Port 5672

var uriBuilder = new UriBuilder("amqp://localhost")
 
 Port = 5672
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

On using the above piece of code in activeMqBusFactory I run into the following exception:
MassTransit.ActiveMqTransport.ActiveMqTransportConfigurationException: 'The address scheme was invalid: amqp'

On changing the above code to

var uriBuilder = new UriBuilder("activemq://localhost")
 
 Port = 5672
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

I get no exception but the webApp gets stuck with message
Starting bus hosts...
Connecting: admin@localhost:5672

Just to clarify if I expose the port 61616 when running the docker container and use the following code

var uriBuilder = new UriBuilder("activemq://localhost")
 
 Port = 61616
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

I am able to connect to activeMQ using OpenWire Connector. I am looking for a way to connect using AMQP connector.

Thanks

c# .net-core activemq amqp masstransit

share|improve this question

asked Mar 27 at 13:07

Vinayak DineshVinayak Dinesh

822 bronze badges

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  From looking at the code, it doesn't seem to expose that capability at this point. I'm not sure if it's supported by the ActiveMQ.NMS library either.
  
  – Chris Patterson
  Mar 27 at 15:17
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  I was able to connect through AMQP connector without masstransit using the example on the following link. [link] (github.com/apache/activemq-artemis/blob/master/examples/…)
  
  – Vinayak Dinesh
  Mar 28 at 6:17
  
  

  
  
  
  

add a comment | 

1

Using MassTransit I'm trying to connect to ActiveMQ using AMQP connector. MassTransit is configured to connect using OpenWire connector to port 61616.

Created a local container for ActiveMq using the following command

docker run --rm -d -p 5672:5672 -p 8161:8161 rmohr/activemq:5.15.6-alpine

Now when trying to connect to MassTransit I am passing the Port 5672

var uriBuilder = new UriBuilder("amqp://localhost")
 
 Port = 5672
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

On using the above piece of code in activeMqBusFactory I run into the following exception:
MassTransit.ActiveMqTransport.ActiveMqTransportConfigurationException: 'The address scheme was invalid: amqp'

On changing the above code to

var uriBuilder = new UriBuilder("activemq://localhost")
 
 Port = 5672
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

I get no exception but the webApp gets stuck with message
Starting bus hosts...
Connecting: admin@localhost:5672

Just to clarify if I expose the port 61616 when running the docker container and use the following code

var uriBuilder = new UriBuilder("activemq://localhost")
 
 Port = 61616
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

I am able to connect to activeMQ using OpenWire Connector. I am looking for a way to connect using AMQP connector.

Thanks

c# .net-core activemq amqp masstransit

share|improve this question

asked Mar 27 at 13:07

Vinayak DineshVinayak Dinesh

822 bronze badges

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  From looking at the code, it doesn't seem to expose that capability at this point. I'm not sure if it's supported by the ActiveMQ.NMS library either.
  
  – Chris Patterson
  Mar 27 at 15:17
  

  
  
  
  


• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  I was able to connect through AMQP connector without masstransit using the example on the following link. [link] (github.com/apache/activemq-artemis/blob/master/examples/…)
  
  – Vinayak Dinesh
  Mar 28 at 6:17
  
  

  
  
  
  

add a comment | 

Using MassTransit I'm trying to connect to ActiveMQ using AMQP connector. MassTransit is configured to connect using OpenWire connector to port 61616.

Created a local container for ActiveMq using the following command

docker run --rm -d -p 5672:5672 -p 8161:8161 rmohr/activemq:5.15.6-alpine

Now when trying to connect to MassTransit I am passing the Port 5672

var uriBuilder = new UriBuilder("amqp://localhost")
 
 Port = 5672
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

On using the above piece of code in activeMqBusFactory I run into the following exception:
MassTransit.ActiveMqTransport.ActiveMqTransportConfigurationException: 'The address scheme was invalid: amqp'

On changing the above code to

var uriBuilder = new UriBuilder("activemq://localhost")
 
 Port = 5672
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

I get no exception but the webApp gets stuck with message
Starting bus hosts...
Connecting: admin@localhost:5672

Just to clarify if I expose the port 61616 when running the docker container and use the following code

var uriBuilder = new UriBuilder("activemq://localhost")
 
 Port = 61616
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

I am able to connect to activeMQ using OpenWire Connector. I am looking for a way to connect using AMQP connector.

Thanks

c# .net-core activemq amqp masstransit

share|improve this question

asked Mar 27 at 13:07

Vinayak DineshVinayak Dinesh

822 bronze badges

docker run --rm -d -p 5672:5672 -p 8161:8161 rmohr/activemq:5.15.6-alpine

var uriBuilder = new UriBuilder("amqp://localhost")
 
 Port = 5672
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

var uriBuilder = new UriBuilder("activemq://localhost")
 
 Port = 5672
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

var uriBuilder = new UriBuilder("activemq://localhost")
 
 Port = 61616
 ;

 var serviceBusHost = cfg.Host(
 uriBuilder.Uri, settings =>
 
 settings.Password(credentials[0]);
 settings.Username(credentials[1]);
 );

share|improve this question

asked Mar 27 at 13:07

Vinayak DineshVinayak Dinesh

822 bronze badges

share|improve this question

asked Mar 27 at 13:07

Vinayak DineshVinayak Dinesh

822 bronze badges

asked Mar 27 at 13:07

Vinayak DineshVinayak Dinesh

822 bronze badges

asked Mar 27 at 13:07

Vinayak DineshVinayak Dinesh

822 bronze badges

1 Answer
1

active

oldest

votes

1

Looking at the source for MassTransit it would appear that you can't use an AMQP connection to an ActiveMQ broker right now. The code uses the NMS.ActiveMQ library which is openwire only so you need to stick with that. The authors would need to support AMQP as a protocol connector using something like the AmqpNetLite client as a general purpose AMQP connector for any message platform that supports it.

share|improve this answer

answered Mar 27 at 21:20

Tim BishTim Bish

13.3k44 gold badges2525 silver badges3838 bronze badges

add a comment | 

Your Answer

StackExchange.ifUsing("editor", function ()
StackExchange.using("externalEditor", function ()
StackExchange.using("snippets", function ()
StackExchange.snippets.init();
);
);
, "code-snippets");

StackExchange.ready(function()
var channelOptions =
tags: "".split(" "),
id: "1"
;
initTagRenderer("".split(" "), "".split(" "), channelOptions);

StackExchange.using("externalEditor", function()
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled)
StackExchange.using("snippets", function()
createEditor();
);

else
createEditor();

);

function createEditor()
StackExchange.prepareEditor(
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader:
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
,
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
);



);

draft saved

draft discarded

Sign up or log in

StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);

Sign up using Google

Sign up using Facebook

Sign up using Email and Password

Post as a guest

Name

Email

Required, but never shown

StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55377995%2funable-to-set-connector-as-amqp-when-connecting-to-activemq-using-masstransit%23new-answer', 'question_page');

);

Post as a guest

Name

Email

Required, but never shown

1

Looking at the source for MassTransit it would appear that you can't use an AMQP connection to an ActiveMQ broker right now. The code uses the NMS.ActiveMQ library which is openwire only so you need to stick with that. The authors would need to support AMQP as a protocol connector using something like the AmqpNetLite client as a general purpose AMQP connector for any message platform that supports it.

share|improve this answer

answered Mar 27 at 21:20

Tim BishTim Bish

13.3k44 gold badges2525 silver badges3838 bronze badges

add a comment | 

1

Looking at the source for MassTransit it would appear that you can't use an AMQP connection to an ActiveMQ broker right now. The code uses the NMS.ActiveMQ library which is openwire only so you need to stick with that. The authors would need to support AMQP as a protocol connector using something like the AmqpNetLite client as a general purpose AMQP connector for any message platform that supports it.

share|improve this answer

answered Mar 27 at 21:20

Tim BishTim Bish

13.3k44 gold badges2525 silver badges3838 bronze badges

add a comment | 

Looking at the source for MassTransit it would appear that you can't use an AMQP connection to an ActiveMQ broker right now. The code uses the NMS.ActiveMQ library which is openwire only so you need to stick with that. The authors would need to support AMQP as a protocol connector using something like the AmqpNetLite client as a general purpose AMQP connector for any message platform that supports it.

share|improve this answer

answered Mar 27 at 21:20

Tim BishTim Bish

13.3k44 gold badges2525 silver badges3838 bronze badges

share|improve this answer

answered Mar 27 at 21:20

Tim BishTim Bish

13.3k44 gold badges2525 silver badges3838 bronze badges

answered Mar 27 at 21:20

Tim BishTim Bish

13.3k44 gold badges2525 silver badges3838 bronze badges

answered Mar 27 at 21:20

Tim BishTim Bish

13.3k44 gold badges2525 silver badges3838 bronze badges