servicebus - Trying to communicate with azure service bus from android device using proton-j -
i trying make android app talk azure service bus using proton-j library
when try add proton-j-0.11.1 jar file library on android project. try send azure service bus end exception broken epipe broken:
01-15 19:37:02.165: e/proton.messenger(822): error processing connection 01-15 19:37:02.165: e/proton.messenger(822): java.net.socketexception: sendto failed: epipe (broken pipe) 01-15 19:37:02.165: e/proton.messenger(822): @ libcore.io.iobridge.maybethrowaftersendto(iobridge.java:506) 01-15 19:37:02.165: e/proton.messenger(822): @ libcore.io.iobridge.sendto(iobridge.java:489) 01-15 19:37:02.165: e/proton.messenger(822): @ java.nio.socketchannelimpl.writeimpl(socketchannelimpl.java:378) 01-15 19:37:02.165: e/proton.messenger(822): @ java.nio.socketchannelimpl.write(socketchannelimpl.java:336) 01-15 19:37:02.165: e/proton.messenger(822): @ org.apache.qpid.proton.driver.impl.connectorimpl.write(connectorimpl.java:168) 01-15 19:37:02.165: e/proton.messenger(822): @ org.apache.qpid.proton.driver.impl.connectorimpl.process(connectorimpl.java:101) 01-15 19:37:02.165: e/proton.messenger(822): @ org.apache.qpid.proton.messenger.impl.messengerimpl.processactive(messengerimpl.java:738) 01-15 19:37:02.165: e/proton.messenger(822): @ org.apache.qpid.proton.messenger.impl.messengerimpl.waituntil(messengerimpl.java:895) 01-15 19:37:02.165: e/proton.messenger(822): @ org.apache.qpid.proton.messenger.impl.messengerimpl.waituntil(messengerimpl.java:844) 01-15 19:37:02.165: e/proton.messenger(822): @ org.apache.qpid.proton.messenger.impl.messengerimpl.send(messengerimpl.java:417) 01-15 19:37:02.165: e/proton.messenger(822): @ org.apache.qpid.proton.messenger.impl.messengerimpl.send(messengerimpl.java:394) 01-15 19:37:02.165: e/proton.messenger(822): @ com.example.qpidprotonj.mainactivity$1$1.run(mainactivity.java:80) 01-15 19:37:02.165: e/proton.messenger(822): @ java.lang.thread.run(thread.java:856) 01-15 19:37:02.165: e/proton.messenger(822): caused by: libcore.io.errnoexception: sendto failed: epipe (broken pipe) 01-15 19:37:02.165: e/proton.messenger(822): @ libcore.io.posix.sendtobytes(native method) 01-15 19:37:02.165: e/proton.messenger(822): @ libcore.io.posix.sendto(posix.java:146) 01-15 19:37:02.165: e/proton.messenger(822): @ libcore.io.blockguardos.sendto(blockguardos.java:169) 01-15 19:37:02.165: e/proton.messenger(822): @ libcore.io.iobridge.sendto(iobridge.java:487) 01-15 19:37:02.165: e/proton.messenger(822): ... 11 more 01-15 19:37:02.165: e/proton.messenger(822): timeout when waiting condition org.apache.qpid.proton.messenger.impl.messengerimpl$sentsettled@40d08550 after 3000 ms
my code here:
if (messenger.stopped()) messenger.start(); log.d(tag, "create message"); message message = message.factory.create(); log.d(tag, "setting address"); message.setaddress("amqps://<key_name>:<key_value>@tttesting.servicebus.windows.net/topic1"); log.d(tag, "setting subject"); message.setsubject("sujet 1"); log.d(tag, "setting amqp body"); message.setbody(new amqpvalue(edittext.gettext().tostring())); log.d(tag, "put message"); messenger.put(message); final tracker tracker = messenger.outgoingtracker(); log.d(tag, "sending >>>>>>"); messenger.send();
Comments
Post a Comment