|
ActiveMQ example source code file (HttpTransportSupport.java)
The ActiveMQ HttpTransportSupport.java source code/** * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.activemq.transport.http; import java.net.URI; import org.apache.activemq.transport.TransportThreadSupport; import org.apache.activemq.transport.util.TextWireFormat; /** * A useful base class for HTTP Transport implementations. * * */ public abstract class HttpTransportSupport extends TransportThreadSupport { private TextWireFormat textWireFormat; private URI remoteUrl; private String proxyHost; private int proxyPort = 8080; public HttpTransportSupport(TextWireFormat textWireFormat, URI remoteUrl) { this.textWireFormat = textWireFormat; this.remoteUrl = remoteUrl; } public String toString() { return "HTTP Reader " + getRemoteUrl(); } // Properties // ------------------------------------------------------------------------- public String getRemoteAddress() { return remoteUrl.toString(); } public URI getRemoteUrl() { return remoteUrl; } public TextWireFormat getTextWireFormat() { return textWireFormat; } public void setTextWireFormat(TextWireFormat textWireFormat) { this.textWireFormat = textWireFormat; } public String getProxyHost() { return proxyHost; } public void setProxyHost(String proxyHost) { this.proxyHost = proxyHost; } public int getProxyPort() { return proxyPort; } public void setProxyPort(int proxyPort) { this.proxyPort = proxyPort; } } Other ActiveMQ examples (source code examples)Here is a short list of links related to this ActiveMQ HttpTransportSupport.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.