Package org.jboss.netty.handler.codec.http

Examples of org.jboss.netty.handler.codec.http.DefaultHttpRequest.addHeader()

458
459
460
461
462
463
464
465
466
467
468
                String headerValue = tc.convertTo(String.class, it.next());

                if (headerValue != null && headerFilterStrategy != null
                        && !headerFilterStrategy.applyFilterToCamelHeaders(key, headerValue, message.getExchange())) {
                    LOG.trace("HTTP-Header: {}={}", key, headerValue);
                    request.addHeader(key, headerValue);
                }
            }
        }

        Object body = message.getBody();
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
    encoderDecoder.encode(baos, scmp);
    url = new URL(Constants.HTTP, host, port, scmp.getHttpUrlFileQualifier());
    HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, this.url.getPath());
    byte[] buffer = baos.toByteArray();
    // Http header fields
    request.addHeader(HttpHeaders.Names.USER_AGENT, System.getProperty("java.runtime.version"));
    request.addHeader(HttpHeaders.Names.HOST, host);
    request.addHeader(HttpHeaders.Names.ACCEPT, Constants.HTTP_ACCEPT_PARAMS);
    request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
    request.addHeader(HttpHeaders.Names.CONTENT_TYPE, scmp.getBodyType().getMimeType());
    request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.length));
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
    url = new URL(Constants.HTTP, host, port, scmp.getHttpUrlFileQualifier());
    HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, this.url.getPath());
    byte[] buffer = baos.toByteArray();
    // Http header fields
    request.addHeader(HttpHeaders.Names.USER_AGENT, System.getProperty("java.runtime.version"));
    request.addHeader(HttpHeaders.Names.HOST, host);
    request.addHeader(HttpHeaders.Names.ACCEPT, Constants.HTTP_ACCEPT_PARAMS);
    request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
    request.addHeader(HttpHeaders.Names.CONTENT_TYPE, scmp.getBodyType().getMimeType());
    request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.length));
    request.addHeader(HttpHeaders.Names.CACHE_CONTROL, HttpHeaders.Values.NO_CACHE);
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
    HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, this.url.getPath());
    byte[] buffer = baos.toByteArray();
    // Http header fields
    request.addHeader(HttpHeaders.Names.USER_AGENT, System.getProperty("java.runtime.version"));
    request.addHeader(HttpHeaders.Names.HOST, host);
    request.addHeader(HttpHeaders.Names.ACCEPT, Constants.HTTP_ACCEPT_PARAMS);
    request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
    request.addHeader(HttpHeaders.Names.CONTENT_TYPE, scmp.getBodyType().getMimeType());
    request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.length));
    request.addHeader(HttpHeaders.Names.CACHE_CONTROL, HttpHeaders.Values.NO_CACHE);
    request.addHeader(HttpHeaders.Names.PRAGMA, HttpHeaders.Values.NO_CACHE);
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
    byte[] buffer = baos.toByteArray();
    // Http header fields
    request.addHeader(HttpHeaders.Names.USER_AGENT, System.getProperty("java.runtime.version"));
    request.addHeader(HttpHeaders.Names.HOST, host);
    request.addHeader(HttpHeaders.Names.ACCEPT, Constants.HTTP_ACCEPT_PARAMS);
    request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
    request.addHeader(HttpHeaders.Names.CONTENT_TYPE, scmp.getBodyType().getMimeType());
    request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.length));
    request.addHeader(HttpHeaders.Names.CACHE_CONTROL, HttpHeaders.Values.NO_CACHE);
    request.addHeader(HttpHeaders.Names.PRAGMA, HttpHeaders.Values.NO_CACHE);
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
    // Http header fields
    request.addHeader(HttpHeaders.Names.USER_AGENT, System.getProperty("java.runtime.version"));
    request.addHeader(HttpHeaders.Names.HOST, host);
    request.addHeader(HttpHeaders.Names.ACCEPT, Constants.HTTP_ACCEPT_PARAMS);
    request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
    request.addHeader(HttpHeaders.Names.CONTENT_TYPE, scmp.getBodyType().getMimeType());
    request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.length));
    request.addHeader(HttpHeaders.Names.CACHE_CONTROL, HttpHeaders.Values.NO_CACHE);
    request.addHeader(HttpHeaders.Names.PRAGMA, HttpHeaders.Values.NO_CACHE);

    NettyHttpRequesterResponseHandler handler = channel.getPipeline().get(NettyHttpRequesterResponseHandler.class);
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
    request.addHeader(HttpHeaders.Names.USER_AGENT, System.getProperty("java.runtime.version"));
    request.addHeader(HttpHeaders.Names.HOST, host);
    request.addHeader(HttpHeaders.Names.ACCEPT, Constants.HTTP_ACCEPT_PARAMS);
    request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
    request.addHeader(HttpHeaders.Names.CONTENT_TYPE, scmp.getBodyType().getMimeType());
    request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.length));
    request.addHeader(HttpHeaders.Names.CACHE_CONTROL, HttpHeaders.Values.NO_CACHE);
    request.addHeader(HttpHeaders.Names.PRAGMA, HttpHeaders.Values.NO_CACHE);

    NettyHttpRequesterResponseHandler handler = channel.getPipeline().get(NettyHttpRequesterResponseHandler.class);
    handler.setCallback(callback);
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
    request.addHeader(HttpHeaders.Names.HOST, host);
    request.addHeader(HttpHeaders.Names.ACCEPT, Constants.HTTP_ACCEPT_PARAMS);
    request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
    request.addHeader(HttpHeaders.Names.CONTENT_TYPE, scmp.getBodyType().getMimeType());
    request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.length));
    request.addHeader(HttpHeaders.Names.CACHE_CONTROL, HttpHeaders.Values.NO_CACHE);
    request.addHeader(HttpHeaders.Names.PRAGMA, HttpHeaders.Values.NO_CACHE);

    NettyHttpRequesterResponseHandler handler = channel.getPipeline().get(NettyHttpRequesterResponseHandler.class);
    handler.setCallback(callback);
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
    request.addHeader(HttpHeaders.Names.ACCEPT, Constants.HTTP_ACCEPT_PARAMS);
    request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
    request.addHeader(HttpHeaders.Names.CONTENT_TYPE, scmp.getBodyType().getMimeType());
    request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.length));
    request.addHeader(HttpHeaders.Names.CACHE_CONTROL, HttpHeaders.Values.NO_CACHE);
    request.addHeader(HttpHeaders.Names.PRAGMA, HttpHeaders.Values.NO_CACHE);

    NettyHttpRequesterResponseHandler handler = channel.getPipeline().get(NettyHttpRequesterResponseHandler.class);
    handler.setCallback(callback);

    ChannelBuffer channelBuffer = ChannelBuffers.copiedBuffer(buffer);
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
    encoderDecoder.encode(baos, scmp);
    url = new URL(Constants.HTTP, host, port, scmp.getHttpUrlFileQualifier());
    HttpRequest request = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, this.url.getPath());
    byte[] buffer = baos.toByteArray();
    // Http header fields
    request.addHeader(HttpHeaders.Names.USER_AGENT, System.getProperty("java.runtime.version"));
    request.addHeader(HttpHeaders.Names.HOST, host);
    request.addHeader(HttpHeaders.Names.ACCEPT, Constants.HTTP_ACCEPT_PARAMS);
    request.addHeader(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
    request.addHeader(HttpHeaders.Names.CONTENT_TYPE, scmp.getBodyType().getMimeType());
    request.addHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(buffer.length));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.