Login
[x]
Log in using an account from:
Fedora Account System
Red Hat Associate
Red Hat Customer
Or login using a Red Hat Bugzilla account
Forgot Password
Login:
Hide Forgot
Create an Account
Red Hat Bugzilla – Attachment 718037 Details for
Bug 929169
Closing a topic consumer should delete its exclusive auto-delete queue
[?]
New
Simple Search
Advanced Search
My Links
Browse
Requests
Reports
Current State
Search
Tabular reports
Graphical reports
Duplicates
Other Reports
User Changes
Plotly Reports
Bug Status
Bug Severity
Non-Defaults
|
Product Dashboard
Help
Page Help!
Bug Writing Guidelines
What's new
Browser Support Policy
5.0.4.rh83 Release notes
FAQ
Guides index
User guide
Web Services
Contact
Legal
This site requires JavaScript to be enabled to function correctly, please enable it.
Reproducer
test_00808098.java (text/x-java), 1.63 KB, created by
Pavel Moravec
on 2013-03-29 11:28:11 UTC
(
hide
)
Description:
Reproducer
Filename:
MIME Type:
Creator:
Pavel Moravec
Created:
2013-03-29 11:28:11 UTC
Size:
1.63 KB
patch
obsolete
>/* To the extent possible under law, Red Hat, Inc. has dedicated all copyright > * to this software to the public domain worldwide, pursuant to the CC0 Public > * Domain Dedication. This software is distributed without any warranty. See > * <http://creativecommons.org/publicdomain/zero/1.0/>. >*/ > >import javax.jms.Connection; >import javax.jms.Destination; >import javax.jms.Message; >import javax.jms.MessageConsumer; >import javax.jms.Session; > >import org.apache.qpid.client.AMQAnyDestination; >import org.apache.qpid.client.AMQConnection; >import java.io.*; > >public class test_00808098 { > public test_00808098() { > } > > private void subscribe(String destString) throws Exception { > Connection con = new AMQConnection("amqp://client:guest@guest/test?brokerlist='tcp://localhost:5672'"); > con.start(); > Session ssn = con.createSession(false,Session.AUTO_ACKNOWLEDGE); > Destination dest = new AMQAnyDestination(destString); > MessageConsumer consumer = ssn.createConsumer(dest); > Message msg; > System.out.println("Consumer created, press enter to continue"); > BufferedReader stdin = new BufferedReader (new InputStreamReader(System.in)); > stdin.readLine(); > consumer.close(); > System.out.println("Consumer closed, press enter to continue"); > stdin.readLine(); > ssn.close(); > System.out.println("Session closed, press enter to continue"); > stdin.readLine(); > con.close(); > System.out.println("Connection closed, press enter to continue"); > stdin.readLine(); > } > > public static void main(String args[]) throws Exception { > test_00808098 consumer = new test_00808098(); > consumer.subscribe(args[0]); > } >}
You cannot view the attachment while viewing its details because your browser does not support IFRAMEs.
View the attachment on a separate page
.
View Attachment As Raw
Actions:
View
Attachments on
bug 929169
: 718037