You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Bret Godwin <br...@level3.com> on 2015/09/11 21:34:18 UTC
Wrapping Camel components/endpoints
I want to create a new JMS component that wraps the existing camel JMS
component.
Oh and before you say it, yes I realize that I can pass the
connectionFactory to the JMS component. I also have other plans for this
wrapper, so the connectionFactory is not the only thing I will be adding.
Here is some pseudo code for what I am attempting to do:
Mycomponent {
JmsComponent jmscomponent;
createEndpoint() {
jmscomponent = new JmsComponent(camelContext);
new MyEndpoint();
jmsEndpoint = jmsComponent.createEndpoint(“jms:queuename”);
myEndponint.setjmsEndpoint (jmsEndpoint)
}
MyEndpoint {
JmsEndpoint jmsEndpoint
createConsumer() {
craeateTibcoconnectionFactory
jmsEndpoint.createConsumer();
}
createProducer() {
craeateTibcoconnectionFactory
jmsEndpoint.createProducer();
}
I don’t wrap the jmsconsumer and jmsproducer since I am returning them from
the createProducer / createConsumer methods.
This all seems to work – I can see the connection get created from the
consumer and the connection from my connectionfactory, but then nothing
happens. It is as though the listener is not started.
I can invoke a producer with no problem - so it appears to be only the
listener on the consumer that is not starting properly.
So how do I start a wrapped component/endpoint/consumer/producer?
I am running this from a junit test case and I know it works if I just do
from(“jms:bret.test”).to(“mock:result”);
If I do
from(“tibjms:bret.test?connectionfactoryurl=blahblahblah”).to(“mock:result”)
->>>> I get connection factory opened, connection opened. And then mock
fails because no message is returned.
Is this wrapper pattern acceptable for camel components?
Any help would be appreciated.
Thanks,
Here is a trace output
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.String
org.apache.camel.converter.ObjectConverter.toString(java.lang.Integer)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.String
org.apache.camel.converter.ObjectConverter.toString(java.lang.StringBuilder)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.String
org.apache.camel.converter.ObjectConverter.toString(java.lang.StringBuffer)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static char[]
org.apache.camel.converter.ObjectConverter.toCharArray(java.lang.String)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.util.Iterator
org.apache.camel.converter.ObjectConverter.iterator(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Class
org.apache.camel.converter.ObjectConverter.toClass(java.lang.Object,org.apache.camel.Exchange)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Boolean
org.apache.camel.converter.ObjectConverter.toBoolean(java.lang.String)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Boolean
org.apache.camel.converter.ObjectConverter.toBoolean(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Integer
org.apache.camel.converter.ObjectConverter.toInteger(java.lang.String)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Integer
org.apache.camel.converter.ObjectConverter.toInteger(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Long
org.apache.camel.converter.ObjectConverter.toLong(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Long
org.apache.camel.converter.ObjectConverter.toLong(java.lang.String)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Float
org.apache.camel.converter.ObjectConverter.toFloat(java.lang.String)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Float
org.apache.camel.converter.ObjectConverter.toFloat(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Double
org.apache.camel.converter.ObjectConverter.toDouble(java.lang.String)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Double
org.apache.camel.converter.ObjectConverter.toDouble(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Iterable
org.apache.camel.converter.ObjectConverter.iterable(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Byte
org.apache.camel.converter.ObjectConverter.toByte(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static char
org.apache.camel.converter.ObjectConverter.toChar(java.lang.String)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Short
org.apache.camel.converter.ObjectConverter.toShort(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.String
org.apache.camel.converter.ObjectConverter.fromCharArray(char[])
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static boolean
org.apache.camel.converter.ObjectConverter.toBool(java.lang.Object)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.Character
org.apache.camel.converter.ObjectConverter.toCharacter(java.lang.String)
[ main] AnnotationTypeConverterLoader TRACE
Loading converter class: org.apache.camel.impl.converter.FutureTypeConverter
[ main] AnnotationTypeConverterLoader TRACE
Loading converter class: org.apache.camel.component.bean.BeanConverter
[ main] DefaultTypeConverter TRACE Adding
fallback type converter: StaticMethodFallbackTypeConverter: public static
java.lang.Object
org.apache.camel.component.bean.BeanConverter.convertTo(java.lang.Class,org.apache.camel.Exchange,java.lang.Object,org.apache.camel.spi.TypeConverterRegistry)
which can promote: false
[ main] AnnotationTypeConverterLoader TRACE
Loading converter class:
org.apache.camel.component.file.GenericFileConverter
[ main] DefaultTypeConverter TRACE Adding
fallback type converter: StaticMethodFallbackTypeConverter: public static
java.lang.Object
org.apache.camel.component.file.GenericFileConverter.convertTo(java.lang.Class,org.apache.camel.Exchange,java.lang.Object,org.apache.camel.spi.TypeConverterRegistry)
throws
java.io.IOException,org.apache.camel.NoTypeConversionAvailableException
which can promote: false
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.io.InputStream
org.apache.camel.component.file.GenericFileConverter.genericFileToInputStream(org.apache.camel.component.file.GenericFile,org.apache.camel.Exchange)
throws
java.io.IOException,org.apache.camel.NoTypeConversionAvailableException
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.String
org.apache.camel.component.file.GenericFileConverter.genericFileToString(org.apache.camel.component.file.GenericFile,org.apache.camel.Exchange)
throws
java.io.IOException,org.apache.camel.NoTypeConversionAvailableException
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static
java.io.Serializable
org.apache.camel.component.file.GenericFileConverter.genericFileToSerializable(org.apache.camel.component.file.GenericFile,org.apache.camel.Exchange)
throws
java.io.IOException,org.apache.camel.NoTypeConversionAvailableException
[ main] AnnotationTypeConverterLoader TRACE
Loading converter class: org.apache.camel.converter.NIOConverter
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.lang.String
org.apache.camel.converter.NIOConverter.toString(java.nio.ByteBuffer,org.apache.camel.Exchange)
throws java.io.IOException
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static byte[]
org.apache.camel.converter.NIOConverter.toByteArray(java.nio.ByteBuffer)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.io.InputStream
org.apache.camel.converter.NIOConverter.toInputStream(java.nio.ByteBuffer)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.nio.ByteBuffer
org.apache.camel.converter.NIOConverter.toByteBuffer(java.lang.Float)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.nio.ByteBuffer
org.apache.camel.converter.NIOConverter.toByteBuffer(java.lang.Long)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.nio.ByteBuffer
org.apache.camel.converter.NIOConverter.toByteBuffer(java.lang.Double)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.nio.ByteBuffer
org.apache.camel.converter.NIOConverter.toByteBuffer(java.lang.Short)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.nio.ByteBuffer
org.apache.camel.converter.NIOConverter.toByteBuffer(byte[])
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.nio.ByteBuffer
org.apache.camel.converter.NIOConverter.toByteBuffer(java.io.File) throws
java.io.IOException
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.nio.ByteBuffer
org.apache.camel.converter.NIOConverter.toByteBuffer(java.lang.String,org.apache.camel.Exchange)
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.nio.ByteBuffer
org.apache.camel.converter.NIOConverter.toByteBuffer(java.lang.Integer)
[ main] AnnotationTypeConverterLoader TRACE
Loading converter class: org.apache.camel.converter.jaxp.StaxConverter
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLEventReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLEventReader(java.io.File,org.apache.camel.Exchange)
throws javax.xml.stream.XMLStreamException,java.io.FileNotFoundException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLEventReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLEventReader(java.io.InputStream,org.apache.camel.Exchange)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLEventReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLEventReader(javax.xml.stream.XMLStreamReader)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLEventReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLEventReader(javax.xml.transform.Source)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLEventReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLEventReader(java.io.Reader)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLEventWriter
org.apache.camel.converter.jaxp.StaxConverter.createXMLEventWriter(javax.xml.transform.Result)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLEventWriter
org.apache.camel.converter.jaxp.StaxConverter.createXMLEventWriter(java.io.Writer)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLEventWriter
org.apache.camel.converter.jaxp.StaxConverter.createXMLEventWriter(java.io.OutputStream,org.apache.camel.Exchange)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLStreamWriter
org.apache.camel.converter.jaxp.StaxConverter.createXMLStreamWriter(java.io.Writer)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLStreamWriter
org.apache.camel.converter.jaxp.StaxConverter.createXMLStreamWriter(javax.xml.transform.Result)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLStreamWriter
org.apache.camel.converter.jaxp.StaxConverter.createXMLStreamWriter(java.io.OutputStream,org.apache.camel.Exchange)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLStreamReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLStreamReader(java.io.Reader)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLStreamReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLStreamReader(java.lang.String)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLStreamReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLStreamReader(javax.xml.transform.Source)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLStreamReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLStreamReader(java.io.File,org.apache.camel.Exchange)
throws javax.xml.stream.XMLStreamException,java.io.FileNotFoundException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.stream.XMLStreamReader
org.apache.camel.converter.jaxp.StaxConverter.createXMLStreamReader(java.io.InputStream,org.apache.camel.Exchange)
throws javax.xml.stream.XMLStreamException
[ main] AnnotationTypeConverterLoader TRACE
Loading converter class: org.apache.camel.converter.jaxp.XmlConverter
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public java.lang.String
org.apache.camel.converter.jaxp.XmlConverter.toString(org.w3c.dom.Node,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public java.lang.String
org.apache.camel.converter.jaxp.XmlConverter.toString(javax.xml.transform.Source,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public java.lang.Boolean
org.apache.camel.converter.jaxp.XmlConverter.toBoolean(org.w3c.dom.NodeList)
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public byte[]
org.apache.camel.converter.jaxp.XmlConverter.toByteArray(javax.xml.transform.Source,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public java.io.InputStream
org.apache.camel.converter.jaxp.XmlConverter.toInputStream(javax.xml.transform.dom.DOMSource,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException,java.io.IOException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public java.io.InputStream
org.apache.camel.converter.jaxp.XmlConverter.toInputStream(org.w3c.dom.Document,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException,java.io.IOException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSource(javax.xml.transform.Source,org.apache.camel.Exchange)
throws
javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSource(java.io.File,org.apache.camel.Exchange)
throws
javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSource(java.io.InputStream,org.apache.camel.Exchange)
throws
javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSource(byte[]) throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.parsers.ParserConfigurationException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSource(java.lang.String)
throws
javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSource(org.w3c.dom.Node)
throws
javax.xml.parsers.ParserConfigurationException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSource(org.w3c.dom.Document)
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.Source
org.apache.camel.converter.jaxp.XmlConverter.toSource(java.lang.String)
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.sax.SAXSource
org.apache.camel.converter.jaxp.XmlConverter.toSAXSource(java.io.InputStream,org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.sax.SAXSource
org.apache.camel.converter.jaxp.XmlConverter.toSAXSource(java.io.File,org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.sax.SAXSource
org.apache.camel.converter.jaxp.XmlConverter.toSAXSource(javax.xml.transform.Source,org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.sax.SAXSource
org.apache.camel.converter.jaxp.XmlConverter.toSAXSource(java.lang.String,org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.sax.SAXSource
org.apache.camel.converter.jaxp.XmlConverter.toSAXSource(byte[],org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
org.apache.camel.BytesSource
org.apache.camel.converter.jaxp.XmlConverter.toBytesSource(byte[])
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Document
org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(org.xml.sax.InputSource,org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.parsers.ParserConfigurationException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Document
org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(java.lang.String,org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.parsers.ParserConfigurationException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Document
org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(java.io.File,org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.parsers.ParserConfigurationException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Document
org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(byte[],org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.parsers.ParserConfigurationException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Document
org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(java.io.InputStream,org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.parsers.ParserConfigurationException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Document
org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(java.io.Reader,org.apache.camel.Exchange)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.parsers.ParserConfigurationException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Document
org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(org.w3c.dom.Node)
throws
javax.xml.parsers.ParserConfigurationException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Document
org.apache.camel.converter.jaxp.XmlConverter.toDOMDocument(javax.xml.transform.Source)
throws
javax.xml.transform.TransformerException,javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stax.StAXSource
org.apache.camel.converter.jaxp.XmlConverter.toStAXSource(java.io.File,org.apache.camel.Exchange)
throws java.io.FileNotFoundException,javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stax.StAXSource
org.apache.camel.converter.jaxp.XmlConverter.toStAXSource(java.lang.String,org.apache.camel.Exchange)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stax.StAXSource
org.apache.camel.converter.jaxp.XmlConverter.toStAXSource(java.io.InputStream,org.apache.camel.Exchange)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stax.StAXSource
org.apache.camel.converter.jaxp.XmlConverter.toStAXSource(byte[],org.apache.camel.Exchange)
throws javax.xml.stream.XMLStreamException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Node
org.apache.camel.converter.jaxp.XmlConverter.toDOMNode(javax.xml.transform.Source)
throws
javax.xml.transform.TransformerException,javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Element
org.apache.camel.converter.jaxp.XmlConverter.toDOMElement(org.w3c.dom.Node)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Element
org.apache.camel.converter.jaxp.XmlConverter.toDOMElement(javax.xml.transform.Source)
throws
javax.xml.transform.TransformerException,javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.xml.sax.InputSource
org.apache.camel.converter.jaxp.XmlConverter.toInputSource(java.io.File,org.apache.camel.Exchange)
throws java.io.FileNotFoundException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.xml.sax.InputSource
org.apache.camel.converter.jaxp.XmlConverter.toInputSource(java.io.InputStream,org.apache.camel.Exchange)
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Document
org.apache.camel.converter.jaxp.XmlConverter.toDOMDocumentFromSingleNodeList(org.w3c.dom.NodeList)
throws
javax.xml.parsers.ParserConfigurationException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
org.apache.camel.StringSource
org.apache.camel.converter.jaxp.XmlConverter.toStringSource(java.lang.String)
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSourceFromSAX(javax.xml.transform.sax.SAXSource)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.parsers.ParserConfigurationException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSourceFromStream(javax.xml.transform.stream.StreamSource,org.apache.camel.Exchange)
throws
javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.dom.DOMSource
org.apache.camel.converter.jaxp.XmlConverter.toDOMSourceFromStAX(javax.xml.transform.stax.StAXSource)
throws
java.io.IOException,org.xml.sax.SAXException,javax.xml.parsers.ParserConfigurationException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stream.StreamSource
org.apache.camel.converter.jaxp.XmlConverter.toStreamSource(javax.xml.transform.Source,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stream.StreamSource
org.apache.camel.converter.jaxp.XmlConverter.toStreamSource(byte[],org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stream.StreamSource
org.apache.camel.converter.jaxp.XmlConverter.toStreamSource(java.nio.ByteBuffer,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stream.StreamSource
org.apache.camel.converter.jaxp.XmlConverter.toStreamSource(java.io.Reader)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stream.StreamSource
org.apache.camel.converter.jaxp.XmlConverter.toStreamSource(java.io.InputStream)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stream.StreamSource
org.apache.camel.converter.jaxp.XmlConverter.toStreamSource(java.io.File)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.sax.SAXSource
org.apache.camel.converter.jaxp.XmlConverter.toSAXSourceFromDOM(javax.xml.transform.dom.DOMSource,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.sax.SAXSource
org.apache.camel.converter.jaxp.XmlConverter.toSAXSourceFromStream(javax.xml.transform.stream.StreamSource,org.apache.camel.Exchange)
throws org.xml.sax.SAXException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.sax.SAXSource
org.apache.camel.converter.jaxp.XmlConverter.toSAXSourceFromStAX(javax.xml.transform.stax.StAXSource,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stream.StreamSource
org.apache.camel.converter.jaxp.XmlConverter.toStreamSourceFromDOM(javax.xml.transform.dom.DOMSource,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stream.StreamSource
org.apache.camel.converter.jaxp.XmlConverter.toStreamSourceFromSAX(javax.xml.transform.sax.SAXSource,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public
javax.xml.transform.stream.StreamSource
org.apache.camel.converter.jaxp.XmlConverter.toStreamSourceFromStAX(javax.xml.transform.stax.StAXSource,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public java.io.Reader
org.apache.camel.converter.jaxp.XmlConverter.toReaderFromSource(javax.xml.transform.Source,org.apache.camel.Exchange)
throws javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Node
org.apache.camel.converter.jaxp.XmlConverter.toDOMNodeFromSAX(javax.xml.transform.sax.SAXSource)
throws
javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Node
org.apache.camel.converter.jaxp.XmlConverter.toDOMNodeFromStAX(javax.xml.transform.stax.StAXSource)
throws
javax.xml.parsers.ParserConfigurationException,java.io.IOException,org.xml.sax.SAXException,javax.xml.transform.TransformerException
[ main] DefaultTypeConverter TRACE Adding
type converter: InstanceMethodTypeConverter: public org.w3c.dom.Node
org.apache.camel.converter.jaxp.XmlConverter.toDOMNodeFromSingleNodeList(org.w3c.dom.NodeList)
[ main] AnnotationTypeConverterLoader TRACE
Searching for META-INF/services/org/apache/camel/TypeConverter services
[ main] AnnotationTypeConverterLoader DEBUG
Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve
list of packages, from url:
jar:file:/C:/Users/bgodwin28730/.m2/repository/org/apache/camel/camel-core/2.15.1/camel-core-2.15.1.jar!/META-INF/services/org/apache/camel/TypeConverter
[ main] AnnotationTypeConverterLoader DEBUG
Loading file META-INF/services/org/apache/camel/TypeConverter to retrieve
list of packages, from url:
jar:file:/C:/Users/bgodwin28730/.m2/repository/org/apache/camel/camel-spring/2.15.1/camel-spring-2.15.1.jar!/META-INF/services/org/apache/camel/TypeConverter
[ main] ObjectHelper TRACE
Loading class: org.apache.camel.spring.converter.ResourceConverter using
classloader: sun.misc.Launcher$AppClassLoader@33d626a4
[ main] AnnotationTypeConverterLoader TRACE Loaded
org.apache.camel.spring.converter.ResourceConverter as class class
org.apache.camel.spring.converter.ResourceConverter
[ main] AnnotationTypeConverterLoader DEBUG Loaded
1 @Converter classes
[ main] AnnotationTypeConverterLoader TRACE
Loading converter class: org.apache.camel.spring.converter.ResourceConverter
[ main] DefaultTypeConverter TRACE Adding
type converter: StaticMethodTypeConverter: public static java.io.InputStream
org.apache.camel.spring.converter.ResourceConverter.convertToInputStream(org.springframework.core.io.Resource)
throws java.io.IOException
[ main] DefaultTypeConverter INFO Loaded
183 type converters
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Service already started
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] DefaultCamelContext TRACE
Getting endpoint with uri:
tibjms:foo?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.2
[ main] DefaultCamelContext TRACE
Getting endpoint with raw uri:
tibjms:foo?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.2,
normalized uri:
tibjms://foo?destinationName=test.2&tibcoJndiUri=tibjmsnaming%3A%2F%2Ftibems01.dev4.idc1.mycompany.com%3A7111%2Ctibjmsnaming%3A%2F%2Ftibems02.dev4.idc1.mycompany.com%3A7111
[ main] DefaultCamelContext TRACE
Endpoint uri:
tibjms://foo?destinationName=test.2&tibcoJndiUri=tibjmsnaming%3A%2F%2Ftibems01.dev4.idc1.mycompany.com%3A7111%2Ctibjmsnaming%3A%2F%2Ftibems02.dev4.idc1.mycompany.com%3A7111
is from component with name: tibjms
[ main] DefaultCamelContext DEBUG Using
ComponentResolver: org.apache.camel.impl.DefaultComponentResolver@369ef286
to resolve component with name: tibjms
[ main] DefaultComponentResolver DEBUG Found
component: tibjms in registry: null
[ main] ObjectHelper TRACE
Loading class: com.mycompany.component.TibcoJmsComponent using classloader:
sun.misc.Launcher$AppClassLoader@33d626a4
[ main] DefaultComponentResolver DEBUG Found
component: tibjms via type: com.mycompany.component.TibcoJmsComponent via:
META-INF/services/org/apache/camel/component/tibjms
[ main] DefaultCamelBeanPostProcessor TRACE Camel
bean processing before initialization for bean:
com.mycompany.component.TibcoJmsComponent
[ main] DefaultCamelBeanPostProcessor TRACE Camel
bean processing after initialization for bean:
com.mycompany.component.TibcoJmsComponent
[ main] ServiceSupport TRACE
Starting service
[ main] DefaultCamelContext TRACE
getComponent(tibjms) -> com.mycompany.component.TibcoJmsComponent@52e3d345
[ main] DefaultCamelContext TRACE
Creating endpoint from uri:
tibjms://foo?destinationName=test.2&tibcoJndiUri=tibjmsnaming%3A%2F%2Ftibems01.dev4.idc1.mycompany.com%3A7111%2Ctibjmsnaming%3A%2F%2Ftibems02.dev4.idc1.mycompany.com%3A7111
using component: com.mycompany.component.TibcoJmsComponent@52e3d345
[ main] DefaultComponent TRACE
Creating endpoint uri=[tibjms://stuff...stuff?destinationName=test.2,
path=[foo], parameters=[{destinationName=test.2,
tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111}]
[ main] IntrospectionSupport DEBUG
Configured property: destinationName on bean:
Endpoint[tibjms://stuff...stuff?destinationName=test.2 with value: test.2
[ main] IntrospectionSupport DEBUG
Configured property: tibcoJndiUri on bean:
Endpoint[tibjms://stuff...stuff?destinationName=test.2 with value:
tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111
[ main] DefaultComponent TRACE
Creating endpoint uri=[jms:test.2], path=[test.2], parameters=[{}]
[ main] DefaultCamelContext DEBUG
tibjms://foo?destinationName=test.2&tibcoJndiUri=tibjmsnaming%3A%2F%2Ftibems01.dev4.idc1.mycompany.com%3A7111%2Ctibjmsnaming%3A%2F%2Ftibems02.dev4.idc1.mycompany.com%3A7111
converted to endpoint:
Endpoint[tibjms://stuff...stuff?destinationName=test.2 by component:
com.mycompany.component.TibcoJmsComponent@52e3d345
[ main] ServiceSupport TRACE
Starting service
[ main] ProcessorDefinitionHelper TRACE
Resolving property placeholders for:
To[tibjms:bar?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.3]
[ main] ProcessorDefinitionHelper TRACE There
are 10 properties on:
To[tibjms:bar?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.3]
[ main] ProcessorDefinitionHelper TRACE
Resolving known fields for:
To[tibjms:bar?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.3]
[ main] ProcessorDefinitionHelper TRACE There
are 10 properties on:
To[tibjms:bar?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.3]
[ main] DefaultCamelContext TRACE
Getting endpoint with uri:
tibjms:bar?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.3
[ main] DefaultCamelContext TRACE
Getting endpoint with raw uri:
tibjms:bar?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.3,
normalized uri:
tibjms://bar?destinationName=test.3&tibcoJndiUri=tibjmsnaming%3A%2F%2Ftibems01.dev4.idc1.mycompany.com%3A7111%2Ctibjmsnaming%3A%2F%2Ftibems02.dev4.idc1.mycompany.com%3A7111
[ main] DefaultCamelContext TRACE
Endpoint uri:
tibjms://bar?destinationName=test.3&tibcoJndiUri=tibjmsnaming%3A%2F%2Ftibems01.dev4.idc1.mycompany.com%3A7111%2Ctibjmsnaming%3A%2F%2Ftibems02.dev4.idc1.mycompany.com%3A7111
is from component with name: tibjms
[ main] DefaultCamelContext TRACE
getComponent(tibjms) -> com.mycompany.component.TibcoJmsComponent@52e3d345
[ main] DefaultCamelContext TRACE
Creating endpoint from uri:
tibjms://bar?destinationName=test.3&tibcoJndiUri=tibjmsnaming%3A%2F%2Ftibems01.dev4.idc1.mycompany.com%3A7111%2Ctibjmsnaming%3A%2F%2Ftibems02.dev4.idc1.mycompany.com%3A7111
using component: com.mycompany.component.TibcoJmsComponent@52e3d345
[ main] DefaultComponent TRACE
Creating endpoint uri=tibjms://stuff...stuff?destinationName=test.2,
path=[bar], parameters=[{destinationName=test.3,
tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111}]
[ main] IntrospectionSupport DEBUG
Configured property: destinationName on bean:
Endpointtibjms://stuff...stuff?destinationName=test.2 with value: test.3
[ main] IntrospectionSupport DEBUG
Configured property: tibcoJndiUri on bean:
Endpointtibjms://stuff...stuff?destinationName=test.2 with value:
tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111
[ main] DefaultComponent TRACE
Creating endpoint uri=[jms:test.3], path=[test.3], parameters=[{}]
[ main] DefaultCamelContext DEBUG
tibjms://bar?destinationName=test.3&tibcoJndiUri=tibjmsnaming%3A%2F%2Ftibems01.dev4.idc1.mycompany.com%3A7111%2Ctibjmsnaming%3A%2F%2Ftibems02.dev4.idc1.mycompany.com%3A7111
converted to endpoint: Endpointtibjms://stuff...stuff?destinationName=test.2
by component: com.mycompany.component.TibcoJmsComponent@52e3d345
[ main] ServiceSupport TRACE
Starting service
[ main] DefaultChannel DEBUG
Initialize channel for target:
'To[tibjms:bar?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.3]'
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ToDefinition TRACE
To[tibjms:bar?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.3]
is configured to inheritErrorHandler
[ main] ToDefinition TRACE
To[tibjms:bar?tibcoJndiUri=tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111&destinationName=test.3]
wrapped in Channel:
Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[ main] ToDefinition TRACE Adding
event driven processor:
Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[ main] ProcessorDefinitionHelper TRACE
Resolving property placeholders for: To[mock:result]
[ main] ProcessorDefinitionHelper TRACE There
are 10 properties on: To[mock:result]
[ main] ProcessorDefinitionHelper TRACE
Resolving known fields for: To[mock:result]
[ main] ProcessorDefinitionHelper TRACE There
are 10 properties on: To[mock:result]
[ main] DefaultCamelContext TRACE
Getting endpoint with uri: mock:result
[ main] DefaultCamelContext TRACE
Getting endpoint with raw uri: mock:result, normalized uri: mock://result
[ main] DefaultCamelContext TRACE
Endpoint uri: mock://result is from component with name: mock
[ main] DefaultCamelContext DEBUG Using
ComponentResolver: org.apache.camel.impl.DefaultComponentResolver@369ef286
to resolve component with name: mock
[ main] DefaultComponentResolver DEBUG Found
component: mock in registry: null
[ main] ObjectHelper TRACE
Loading class: org.apache.camel.component.mock.MockComponent using
classloader: sun.misc.Launcher$AppClassLoader@33d626a4
[ main] DefaultComponentResolver DEBUG Found
component: mock via type: org.apache.camel.component.mock.MockComponent via:
META-INF/services/org/apache/camel/component/mock
[ main] DefaultCamelBeanPostProcessor TRACE Camel
bean processing before initialization for bean:
org.apache.camel.component.mock.MockComponent
[ main] DefaultCamelBeanPostProcessor TRACE Camel
bean processing after initialization for bean:
org.apache.camel.component.mock.MockComponent
[ main] ServiceSupport TRACE
Starting service
[ main] DefaultCamelContext TRACE
getComponent(mock) -> org.apache.camel.component.mock.MockComponent@ca753f7
[ main] DefaultCamelContext TRACE
Creating endpoint from uri: mock://result using component:
org.apache.camel.component.mock.MockComponent@ca753f7
[ main] DefaultComponent TRACE
Creating endpoint uri=[mock://result], path=[result], parameters=[{}]
[ main] DefaultCamelContext DEBUG
mock://result converted to endpoint: Endpoint[mock://result] by component:
org.apache.camel.component.mock.MockComponent@ca753f7
[ main] ServiceSupport TRACE
Starting service
[ main] DefaultChannel DEBUG
Initialize channel for target: 'To[mock:result]'
[ main] ServiceSupport TRACE
Service already started
[ main] ServiceSupport TRACE
Service already started
[ main] ToDefinition TRACE
To[mock:result] is configured to inheritErrorHandler
[ main] ToDefinition TRACE
To[mock:result] wrapped in Channel: Channel[sendTo(Endpoint[mock://result])]
[ main] ToDefinition TRACE Adding
event driven processor: Channel[sendTo(Endpoint[mock://result])]
[ main] DefaultCamelContext INFO
AllowUseOriginalMessage is enabled. If access to the original message is not
needed, then its recommended to turn this option off as it may improve
performance.
[ main] DefaultCamelContext INFO
StreamCaching is not in use. If using streams then its recommended to enable
stream caching. See more details at
http://camel.apache.org/stream-caching.html
[ main] DefaultCamelContext DEBUG
Warming up route id: route1 having autoStartup=true
[ main] ServiceSupport TRACE
Service already started
[ main] RouteService DEBUG
Starting services on route: route1
----->Bundle context NOT found
[ main] JmsQueueEndpoint DEBUG Using
destinationName: test.2 on listenerContainer:
[ main] DefaultExecutorServiceManager DEBUG
Created new CachedThreadPool for source: Consumer[jms:test.2] with name:
JmsConsumer[null]. ->
java.util.concurrent.ThreadPoolExecutor@568ad4f0[Running, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 0]
[ main] RouteService DEBUG
Starting child service on route: route1 ->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Service already started
[ main] ServiceSupport TRACE
Service already started
[ main] SharedProducerServicePool TRACE No
free services in pool to acquire for key:
Endpointtibjms://stuff...stuff?destinationName=test.2
----->Bundle context NOT found
[ main] ServiceSupport TRACE
Starting service
[ main] JmsProducer DEBUG
Starting producer: Producer[jms:test.3]
[ main] ProducerCache DEBUG Adding
to producer cache with key:
Endpointtibjms://stuff...stuff?destinationName=test.2 for producer:
Producer[jms:test.3]
[ main] ServiceSupport TRACE
Service already started
[ main] DefaultErrorHandler DEBUG
Redelivery enabled: false on error handler:
DefaultErrorHandler[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[ main] ServiceSupport TRACE
Service already started
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Starting service
[ main] ServiceSupport TRACE
Service already started
[ main] ServiceSupport TRACE
Service already started
[ main] SharedProducerServicePool TRACE No
free services in pool to acquire for key: Endpoint[mock://result]
[ main] ServiceSupport TRACE
Starting service
[ main] MockEndpoint$1 DEBUG
Starting producer: Producer[mock://result]
[ main] ProducerCache DEBUG Adding
to producer cache with key: Endpoint[mock://result] for producer:
Producer[mock://result]
[ main] ServiceSupport TRACE
Service already started
[ main] DefaultErrorHandler DEBUG
Redelivery enabled: false on error handler:
DefaultErrorHandler[sendTo(Endpoint[mock://result])]
[ main] ServiceSupport TRACE
Service already started
[ main] RouteService DEBUG
Starting child service on route: route1 ->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[ main] ServiceSupport TRACE
Service already started
[ main] RouteService DEBUG
Starting child service on route: route1 ->
sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)
[ main] ServiceSupport TRACE
Service already started
[ main] RouteService DEBUG
Starting child service on route: route1 ->
Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[ main] ServiceSupport TRACE
Service already started
[ main] RouteService DEBUG
Starting child service on route: route1 -> sendTo(Endpoint[mock://result])
[ main] ServiceSupport TRACE
Service already started
[ main] RouteService DEBUG
Starting child service on route: route1 ->
Channel[sendTo(Endpoint[mock://result])]
[ main] ServiceSupport TRACE
Service already started
[ main] DefaultCamelContext DEBUG Route:
route1 >>>
EventDrivenConsumerRoute[Endpoint[tibjms://stuff...stuff?destinationName=test.2
->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]]
[ main] DefaultCamelContext DEBUG
Starting consumer (order: 1000) on route: route1
[ main] ServiceSupport TRACE
Starting service
[ main] JmsConsumer DEBUG
Starting consumer: Consumer[jms:test.2]
[ main] ServiceSupport TRACE
Service already started
[ main] JmsConsumer TRACE
Starting listener container
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@53d23f53
on destination test.2
[ main] ConnectionFactoryServiceImpl INFO JMS
Connection returned
[ main] ConnectionFactoryServiceImpl INFO
Creating Tibco Connection Factory using url:
tibjmsnaming://tibems01.dev4.idc1.mycompany.com:7111,tibjmsnaming://tibems02.dev4.idc1.mycompany.com:7111
[ main] ultJmsMessageListenerContainer DEBUG
Established shared JMS Connection
[ main] CamelThreadFactory TRACE
Created thread[Camel (camel-1) thread #0 - JmsConsumer[null]] ->
Thread[Camel (camel-1) thread #0 - JmsConsumer[null],5,main]
[ main] ultJmsMessageListenerContainer DEBUG
Resumed paused task:
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker@772baaac
[ thread #0 - JmsConsumer[null]] ultJmsMessageListenerContainer TRACE
runningAllowed() -> false
[ main] JmsConsumer DEBUG
Started listener container
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@53d23f53
on destination test.2
[ main] DefaultCamelContext INFO Route:
route1 started and consuming from: Endpoint[jms:test.2]
[ main] ServiceSupport TRACE
Starting service
[ main] EventHelper TRACE
Notifier: org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8 is
not enabled for the event: Started route: route1
[ main] DefaultCamelContext INFO Total
1 routes, of which 1 is started.
[ main] DefaultCamelContext INFO Apache
Camel 2.15.1 (CamelContext: camel-1) started in 1.788 seconds
[ main] EventHelper TRACE
Notifier: org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8 is
not enabled for the event: Started CamelContext: camel-1
[ main] TibcoJmsComponentTest DEBUG
Routing Rules are:
[EventDrivenConsumerRoute[Endpoint[tibjms://stuff...stuff?destinationName=test.2
->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]]]
[ main] DefaultCamelContext TRACE
Getting endpoint with uri: mock:result
[ main] DefaultCamelContext TRACE
Getting endpoint with raw uri: mock:result, normalized uri: mock://result
did it
[ main] MockEndpoint INFO
Asserting: Endpoint[mock://result] is satisfied
[ main] MockEndpoint DEBUG
Waiting on the latch for: 0 millis
[ main] MockEndpoint DEBUG Took
10002 millis to complete latch
[ main] TibcoJmsComponentTest INFO
********************************************************************************
[ main] TibcoJmsComponentTest INFO
Testing done:
testTibcoJms(com.mycompany.TibcoJmsComponent.TibcoJmsComponentTest)
[ main] TibcoJmsComponentTest INFO Took:
10.003 seconds (10003 millis)
[ main] TibcoJmsComponentTest INFO
********************************************************************************
[ main] CamelTestSupport DEBUG
tearDown test
[ main] ServiceHelper TRACE
Stopping service ConsumerCache for source:
org.apache.camel.impl.DefaultConsumerTemplate@1f37c18b, capacity: 1000
[ main] ServiceHelper TRACE
Stopping service
org.apache.camel.impl.SharedPollingConsumerServicePool@5839cb0
[ main] ServiceHelper TRACE
Shutting down service ConsumerCache for source:
org.apache.camel.impl.DefaultConsumerTemplate@1f37c18b, capacity: 1000
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service ProducerCache for source:
org.apache.camel.impl.DefaultProducerTemplate@3a3e9a4, capacity: 1000
[ main] ServiceHelper TRACE
Stopping service org.apache.camel.impl.SharedProducerServicePool@28ac3f94
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.SharedProducerServicePool@28ac3f94
[ main] ServiceSupport TRACE
Service already stopped
[ main] SharedProducerServicePool DEBUG
Stopping service pool:
org.apache.camel.impl.SharedProducerServicePool@28ac3f94
[ main] DefaultCamelContext INFO Apache
Camel 2.15.1 (CamelContext: camel-1) is shutting down
[ main] EventHelper TRACE
Notifier: org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8 is
not enabled for the event: Stopping CamelContext: camel-1
[ main] DefaultShutdownStrategy INFO
Starting to graceful shutdown 1 routes (timeout 60 seconds)
[ main] DefaultExecutorServiceManager DEBUG
Created new ThreadPool for source:
org.apache.camel.impl.DefaultShutdownStrategy@a690707 with name:
ShutdownTask. ->
org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@55cf055c[Running,
pool size = 0, active threads = 0, queued tasks = 0, completed tasks =
0][ShutdownTask]
[ main] CamelThreadFactory TRACE
Created thread[Camel (camel-1) thread #1 - ShutdownTask] -> Thread[Camel
(camel-1) thread #1 - ShutdownTask,5,main]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy DEBUG There
are 1 routes to shutdown
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy TRACE
Shutting down route: route1 with options [Default,CompleteCurrentTaskOnly]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy TRACE
Suspending: Consumer[jms:test.2]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Suspending service Consumer[jms:test.2]
[el-1) thread #1 - ShutdownTask] ultJmsMessageListenerContainer DEBUG
Stopping listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@53d23f53
with cacheLevel: 3 and sharedConnectionEnabled: true
[el-1) thread #1 - ShutdownTask] ultJmsMessageListenerContainer DEBUG
Stopping shared connection on listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@53d23f53
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy TRACE
Suspend complete for: Consumer[jms:test.2]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy DEBUG Route:
route1 suspended and shutdown deferred, was consuming from:
Endpoint[tibjms://stuff...stuff?destinationName=test.2
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy TRACE
Preparing shutdown on
DefaultErrorHandler[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[el-1) thread #1 - ShutdownTask] DefaultErrorHandler TRACE
Prepare shutdown on error handler
DefaultErrorHandler[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy TRACE
Preparing shutdown on DefaultErrorHandler[sendTo(Endpoint[mock://result])]
[el-1) thread #1 - ShutdownTask] DefaultErrorHandler TRACE
Prepare shutdown on error handler
DefaultErrorHandler[sendTo(Endpoint[mock://result])]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy TRACE
Shutting down: Consumer[jms:test.2]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service Consumer[jms:test.2]
[el-1) thread #1 - ShutdownTask] ultJmsMessageListenerContainer DEBUG
Stopping listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@53d23f53
with cacheLevel: 3 and sharedConnectionEnabled: true
[el-1) thread #1 - ShutdownTask] ultJmsMessageListenerContainer DEBUG
Stopping shared connection on listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@53d23f53
[el-1) thread #1 - ShutdownTask] ultJmsMessageListenerContainer DEBUG
Destroying listenerContainer:
org.apache.camel.component.jms.DefaultJmsMessageListenerContainer@53d23f53
with cacheLevel: 3 and sharedConnectionEnabled: true
[el-1) thread #1 - ShutdownTask] ultJmsMessageListenerContainer DEBUG
Shutting down JMS listener container
[el-1) thread #1 - ShutdownTask] ultJmsMessageListenerContainer DEBUG
Waiting for shutdown of message listener invokers
[ thread #0 - JmsConsumer[null]] ultJmsMessageListenerContainer DEBUG
Lowered scheduled invoker count: 0
[el-1) thread #1 - ShutdownTask] DefaultExecutorServiceManager DEBUG
Forcing shutdown of ExecutorService:
java.util.concurrent.ThreadPoolExecutor@568ad4f0[Running, pool size = 1,
active threads = 0, queued tasks = 0, completed tasks = 1]
[el-1) thread #1 - ShutdownTask] DefaultExecutorServiceManager TRACE
Shutdown of ExecutorService:
java.util.concurrent.ThreadPoolExecutor@568ad4f0[Terminated, pool size = 0,
active threads = 0, queued tasks = 0, completed tasks = 1] is shutdown: true
and terminated: false.
[el-1) thread #1 - ShutdownTask] JmsConsumer DEBUG
Stopping consumer: Consumer[jms:test.2]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service
Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service
sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service ProducerCache for source:
sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2), capacity: -1
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Service already stopped:
org.apache.camel.impl.SharedProducerServicePool@28ac3f94
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.SharedProducerServicePool@28ac3f94
[el-1) thread #1 - ShutdownTask] ServiceSupport TRACE
Service already shut down
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service Producer[jms:test.3]
[el-1) thread #1 - ShutdownTask] JmsProducer DEBUG
Stopping producer: Producer[jms:test.3]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Shutting down service: Producer[jms:test.3]
[el-1) thread #1 - ShutdownTask] ServiceSupport TRACE
Service already stopped
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Service already stopped: Producer[jms:test.3]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service
DefaultErrorHandler[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service Channel[sendTo(Endpoint[mock://result])]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service sendTo(Endpoint[mock://result])
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service ProducerCache for source: sendTo(Endpoint[mock://result]),
capacity: -1
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Service already stopped:
org.apache.camel.impl.SharedProducerServicePool@28ac3f94
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.SharedProducerServicePool@28ac3f94
[el-1) thread #1 - ShutdownTask] ServiceSupport TRACE
Service already shut down
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service Producer[mock://result]
[el-1) thread #1 - ShutdownTask] MockEndpoint$1 DEBUG
Stopping producer: Producer[mock://result]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Shutting down service: Producer[mock://result]
[el-1) thread #1 - ShutdownTask] ServiceSupport TRACE
Service already stopped
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Service already stopped: Producer[mock://result]
[el-1) thread #1 - ShutdownTask] ServiceHelper TRACE
Stopping service DefaultErrorHandler[sendTo(Endpoint[mock://result])]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy TRACE
Shutdown complete for: Consumer[jms:test.2]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy INFO Route:
route1 shutdown complete, was consuming from: Endpoint[jms:test.2]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy TRACE
Preparing shutdown on
DefaultErrorHandler[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[el-1) thread #1 - ShutdownTask] DefaultErrorHandler TRACE
Prepare shutdown on error handler
DefaultErrorHandler[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[el-1) thread #1 - ShutdownTask] DefaultShutdownStrategy TRACE
Preparing shutdown on DefaultErrorHandler[sendTo(Endpoint[mock://result])]
[el-1) thread #1 - ShutdownTask] DefaultErrorHandler TRACE
Prepare shutdown on error handler
DefaultErrorHandler[sendTo(Endpoint[mock://result])]
[ main] DefaultShutdownStrategy INFO
Graceful shutdown of 1 routes completed in 0 seconds
[ main] ServiceHelper TRACE
Stopping service
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager@495e32f9
[ main] aultAsyncProcessorAwaitManager DEBUG
Shutting down with no inflight threads.
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager@495e32f9
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service org.apache.camel.impl.RouteService@47649f10
[ main] RouteService DEBUG
Stopping services on route: route1
[ main] RouteService DEBUG
Shutting down child service on route: route1 -> Consumer[jms:test.2]
[ main] ServiceHelper TRACE
Service already stopped: Consumer[jms:test.2]
[ main] ServiceHelper TRACE
Shutting down service Consumer[jms:test.2]
[ main] ServiceSupport TRACE
Service already stopped
[ main] RouteService DEBUG
Shutting down child service on route: route1 ->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[ main] ServiceHelper TRACE
Service already stopped:
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[ main] ServiceHelper TRACE
Shutting down service
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[ main] ServiceSupport TRACE
Service already stopped
[ main] RouteService DEBUG
Shutting down child service on route: route1 ->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[ main] ServiceHelper TRACE
Service already stopped:
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[ main] ServiceHelper TRACE
Shutting down service
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Service already stopped:
Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[ main] ServiceHelper TRACE
Service already stopped: Channel[sendTo(Endpoint[mock://result])]
[ main] RouteService DEBUG
Shutting down child service on route: route1 ->
sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)
[ main] ServiceHelper TRACE
Service already stopped:
sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)
[ main] ServiceHelper TRACE
Shutting down service
sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Service already stopped: ProducerCache for source:
sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2), capacity: -1
[ main] ServiceHelper TRACE
Shutting down service: ProducerCache for source:
sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2), capacity: -1
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Service already stopped: Producer[jms:test.3]
[ main] ServiceHelper TRACE
Shutting down service: Producer[jms:test.3]
[ main] ServiceSupport TRACE
Service already shut down
[ main] RouteService DEBUG
Shutting down child service on route: route1 ->
Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[ main] ServiceHelper TRACE
Service already stopped:
Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[ main] ServiceHelper TRACE
Shutting down service
Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)]
[ main] ServiceSupport TRACE
Service already stopped
[ main] RouteService DEBUG
Shutting down child service on route: route1 ->
sendTo(Endpoint[mock://result])
[ main] ServiceHelper TRACE
Service already stopped: sendTo(Endpoint[mock://result])
[ main] ServiceHelper TRACE
Shutting down service sendTo(Endpoint[mock://result])
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Service already stopped: ProducerCache for source:
sendTo(Endpoint[mock://result]), capacity: -1
[ main] ServiceHelper TRACE
Shutting down service: ProducerCache for source:
sendTo(Endpoint[mock://result]), capacity: -1
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Service already stopped: Producer[mock://result]
[ main] ServiceHelper TRACE
Shutting down service: Producer[mock://result]
[ main] ServiceSupport TRACE
Service already shut down
[ main] RouteService DEBUG
Shutting down child service on route: route1 ->
Channel[sendTo(Endpoint[mock://result])]
[ main] ServiceHelper TRACE
Service already stopped: Channel[sendTo(Endpoint[mock://result])]
[ main] ServiceHelper TRACE
Shutting down service Channel[sendTo(Endpoint[mock://result])]
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service
EventDrivenConsumerRoute[Endpoint[tibjms://stuff...stuff?destinationName=test.2
->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]]
[ main] ServiceHelper TRACE
Shutting down service:
EventDrivenConsumerRoute[Endpoint[tibjms://stuff...stuff?destinationName=test.2
->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]]
[ main] ServiceSupport TRACE
Service already stopped
[ main] EventHelper TRACE
Notifier: org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8 is
not enabled for the event: Stopped route: route1
[ main] ServiceHelper TRACE
Shutting down service org.apache.camel.impl.RouteService@47649f10
[ main] RouteService DEBUG
Shutting down services on route: route1
[ main] ServiceHelper TRACE
Service already stopped:
EventDrivenConsumerRoute[Endpoint[tibjms://stuff...stuff?destinationName=test.2
->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]]
[ main] ServiceHelper TRACE
Shutting down service:
EventDrivenConsumerRoute[Endpoint[tibjms://stuff...stuff?destinationName=test.2
->
Pipeline[[Channel[sendTo(Endpointtibjms://stuff...stuff?destinationName=test.2)],
Channel[sendTo(Endpoint[mock://result])]]]]
[ main] ServiceSupport TRACE
Service already shut down
[ main] ServiceHelper TRACE
Stopping service Endpoint[tibjms://stuff...stuff?destinationName=test.2
[ main] ServiceHelper TRACE
Shutting down service:
Endpoint[tibjms://stuff...stuff?destinationName=test.2
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service Endpointtibjms://stuff...stuff?destinationName=test.2
[ main] ServiceHelper TRACE
Shutting down service Endpointtibjms://stuff...stuff?destinationName=test.2
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Service already stopped:
Endpoint[tibjms://stuff...stuff?destinationName=test.2
[ main] ServiceHelper TRACE
Shutting down service Endpoint[tibjms://stuff...stuff?destinationName=test.2
[ main] ServiceSupport TRACE
Service already shut down
[ main] ServiceHelper TRACE
Stopping service Endpoint[mock://result]
[ main] ServiceHelper TRACE
Shutting down service Endpoint[mock://result]
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service
org.apache.camel.component.properties.PropertiesComponent@d53b61e
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.component.properties.PropertiesComponent@d53b61e
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service org.apache.camel.component.mock.MockComponent@ca753f7
[ main] ServiceHelper TRACE
Shutting down service org.apache.camel.component.mock.MockComponent@ca753f7
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service com.mycompany.component.TibcoJmsComponent@52e3d345
[ main] ServiceHelper TRACE
Shutting down service com.mycompany.component.TibcoJmsComponent@52e3d345
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service
org.apache.camel.processor.interceptor.BacklogDebugger@1f06f80e
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.processor.interceptor.BacklogDebugger@1f06f80e
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service
org.apache.camel.processor.interceptor.BacklogTracer@2876f0c
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.processor.interceptor.BacklogTracer@2876f0c
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service
org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service org.apache.camel.impl.DefaultRestRegistry@98b7e20
[ main] ServiceHelper TRACE
Shutting down service org.apache.camel.impl.DefaultRestRegistry@98b7e20
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service
org.apache.camel.impl.DefaultPackageScanClassResolver@366953d
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.DefaultPackageScanClassResolver@366953d
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service org.apache.camel.impl.DefaultShutdownStrategy@a690707
[ main] ServiceHelper TRACE
Shutting down service org.apache.camel.impl.DefaultShutdownStrategy@a690707
[ main] ServiceSupport TRACE
Service already stopped
[ main] DefaultExecutorServiceManager DEBUG
Forcing shutdown of ExecutorService:
org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@55cf055c[Running,
pool size = 1, active threads = 0, queued tasks = 0, completed tasks =
1][ShutdownTask]
[ main] DefaultExecutorServiceManager TRACE
Shutdown of ExecutorService:
org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@55cf055c[Shutting
down, pool size = 1, active threads = 0, queued tasks = 0, completed tasks =
1][ShutdownTask] is shutdown: true and terminated: false.
[ main] ServiceHelper TRACE
Service already stopped:
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager@495e32f9
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager@495e32f9
[ main] ServiceSupport TRACE
Service already shut down
[ main] ServiceHelper TRACE
Stopping service org.apache.camel.impl.DefaultInflightRepository@6e66580
[ main] DefaultInflightRepository DEBUG
Shutting down with no inflight exchanges.
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.DefaultInflightRepository@6e66580
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Service already stopped:
org.apache.camel.impl.SharedProducerServicePool@28ac3f94
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.SharedProducerServicePool@28ac3f94
[ main] ServiceSupport TRACE
Service already shut down
[ main] ServiceHelper TRACE
Stopping service EndpointRegistry for camel-1, capacity: 1000
[ main] ServiceHelper TRACE
Stopping service org.apache.camel.impl.converter.DefaultTypeConverter@11ba0a
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.converter.DefaultTypeConverter@11ba0a
[ main] ServiceSupport TRACE
Service already stopped
[ main] EventHelper DEBUG
Ignoring notifying event Stopped CamelContext: camel-1. The EventNotifier
has not been started yet:
org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8
[ main] ServiceHelper TRACE
Service already stopped:
org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8
[ main] ServiceSupport TRACE
Service already shut down
[ main] ServiceHelper TRACE
Stopping service org.apache.camel.impl.DefaultExecutorServiceManager@bcce68f
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.impl.DefaultExecutorServiceManager@bcce68f
[ main] ServiceSupport TRACE
Service already stopped
[ main] ServiceHelper TRACE
Stopping service
org.apache.camel.management.DefaultManagementStrategy@3934bc56
[ main] ServiceHelper TRACE
Service already stopped:
org.apache.camel.impl.DefaultRuntimeEndpointRegistry@4be6d4a8
[ main] ServiceHelper TRACE
Shutting down service
org.apache.camel.management.DefaultManagementStrategy@3934bc56
[ main] ServiceSupport TRACE
Service already stopped
[ main] IntrospectionSupport DEBUG
Clearing cache[size=2, hits=3, misses=2, evicted=0]
[ main] DefaultCamelContext INFO Apache
Camel 2.15.1 (CamelContext: camel-1) uptime 12.037 seconds
[ main] DefaultCamelContext INFO Apache
Camel 2.15.1 (CamelContext: camel-1) is shutdown in 0.230 seconds
[ main] CamelTestSupport DEBUG
tearDownAfterClass test
--
View this message in context: http://camel.465427.n5.nabble.com/Wrapping-Camel-components-endpoints-tp5771456.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Wrapping Camel components/endpoints
Posted by Bret Godwin <br...@level3.com>.
I figured it out after much trial and effort in the debugger.
turns out that I needed another method in my new Endpoint wrapper class.
@Override
protected void doStart() {
try {
jmsEndpoint.start();
} catch (Exception e) {
// handle exception
}
}
and... it works !!!!!
--
View this message in context: http://camel.465427.n5.nabble.com/Wrapping-Camel-components-endpoints-tp5771456p5771458.html
Sent from the Camel - Users mailing list archive at Nabble.com.