node.js - .Net AMQP client for IBM MQ -

-

i trying connect ibm mq 9.0 using amqp 1.0 channel .net application.

the mq light portal supports nodejs, ruby, java , python clients only. have mq light amqp client .net?

i have tried connecting ibm mq 9 amqpnetlite client 

namespace amqpnetlitesample {     class program     {         static void main(string[] args)         {             console.writeline("start");             //address addr = new address("10.58.139.97", 1234, "username","password", "/", "amqp");             address addr = new address("amqp://10.58.139.97:1234");              connection con = new connection(addr);             con.closed += con_closed;             console.writeline("created connection");              session session = new amqp.session(con);             session.closed += session_closed;             console.writeline("created session");              senderlink link = new senderlink(session, "sender_12565455877", "/public");             console.writeline("created link");             var message = new message();             message.properties = new properties();             message.properties.subject = "mysamplemsg";             message.applicationproperties = new applicationproperties();             message.applicationproperties["myprop"] = "hello world";             console.writeline("sending message");             link.send(message);          }          static void session_closed(amqpobject sender, error error)         {             console.writeline("session closed");             console.writeline(error.tostring());         }          static void con_closed(amqpobject sender, error error)         {             console.writeline("connection closed");             console.writeline(error.tostring());         }     } }

but not succeed in establishing connection. when initiating senderlink, getting 2035 mqrc_not_authorized exception. however, without changing of channel authentication in ibm mq 9.0 server, if try mq light nodejs example (send.js), able connect , send messages amqp channel.

please suggest if there changes required in above code.

has succeeded in establishing communication ibm mq other .net 1.0 amqp clients? need here. thanks.

it seems when user name , password not configured, mq broker requires sasl negotiation connection. can enable sasl anonymous on amqpnetlite follows.

address address = new address("amqp://10.58.139.97:1234"); connection connection = new connection(address, saslprofile.anonymous, null, null); session session = new session(connection); senderlink sender = new senderlink(session, "sender-12345", "/public"); message message = new message("hello"); message.properties = new properties() { messageid = "msg", = "q1" }; sender.send(message); connection.close();

it possible same connectionfactory.

address address = new address("amqp://10.58.139.97:1234"); var factory = new connectionfactory(); factory.sasl.profile = saslprofile.anonymous; connection connection = await factory.createasync(address);

Comments

Post a Comment

Popular posts from this blog

Spring Boot + JPA + Hibernate: Unable to locate persister -

-
i trying work entity inside request method of spring boot application. entity in project , pom.xml has dependencies it. why error message?: org.hibernate.unknownentitytypeexception: unable locate persister: com.ric.bill.model.bs.par package com.ric.web; import java.util.concurrent.atomic.atomiclong; import javax.persistence.entitymanager; import javax.persistence.persistencecontext; import net.sf.ehcache.cachemanager; import net.sf.ehcache.management.cache; import net.sf.ehcache.management.cachestatistics; import org.hibernate.stat.statistics; import org.springframework.beans.factory.annotation.autowired; import org.springframework.boot.autoconfigure.domain.entityscan; import org.springframework.cache.annotation.enablecaching; import org.springframework.transaction.annotation.enabletransactionmanagement; import org.springframework.transaction.annotation.propagation; import org.springframework.transaction.annotation.transactional; import org.springframework.web.bind.annotati
Read more

go - Golang: panic: runtime error: invalid memory address or nil pointer dereference using bufio.Scanner -

-
i implementing go program uses bufio.scanner , bufio.writer have packaged code follows package main import ( "fmt" "player/command" "strings" ) func main() { //enter code here. read input stdin. print output stdout commands.scanner.scan() { //scan new line , send comand variable check command exist or not input := strings.split(strings.trim(commands.scanner.text(), " "), " ") command := input[0] if command == "" { fmt.printf("$ %s:", commands.pwd) continue } if !commands.commands[command] { commands.throwerror("cannot recognize input.") } else { commands.execute(command, input[1:], nil) } fmt.printf("$ %s:", commands.pwd) } } i using init.go file in main package follows package main import ( "flag" "player/sourc
Read more

c - double free or corruption (fasttop) -

-
this code reads null terminated string file (file containing null terminated strings & should provide index wanted string). error: *** error in `./main': double free or corruption (fasttop): 0x090a4a80 *** aborted code: char *tmp_realloc=null; char *sstring=null; int i=1; /*set file pointer point string*/ fseek(fh,index,seek_set); sstring=(char*)malloc(sizeof(char)); if(sstring == null) return null; tmp_realloc=sstring; while( (*(sstring+i-1)=(char)fgetc((file*)fh)) != 0x0 ) { /*reallocate more memory*/ tmp_realloc=(char*)realloc((char*)sstring,++i); /*if not same address copy old new & set old point new*/ if(tmp_realloc != sstring){ strcpy((char*)tmp_realloc,(char*)sstring); free(sstring); sstring=tmp_realloc; } } could tell me pointer causing issue (& reason) ? remove part /*if not same address copy old new & set old point new*/ if(tmp_realloc != sstring){ strc
Read more