protected class HTTP2ServerConnectionFactory.HTTPServerSessionListener extends ServerSessionListener.Adapter implements Stream.Listener
Stream.Listener.Adapter
ServerSessionListener.Adapter
Constructor and Description |
---|
HTTPServerSessionListener(Connector connector,
EndPoint endPoint) |
Modifier and Type | Method and Description |
---|---|
protected HTTP2ServerConnection |
getConnection() |
void |
onClose(Session session,
GoAwayFrame frame,
Callback callback)
Callback method invoked when a GOAWAY frame has been received.
|
void |
onData(Stream stream,
DataFrame frame,
Callback callback)
Callback method invoked when a DATA frame has been received.
|
void |
onFailure(Session session,
java.lang.Throwable failure,
Callback callback)
Callback method invoked when a failure has been detected for this session.
|
void |
onFailure(Stream stream,
int error,
java.lang.String reason,
Callback callback)
Callback method invoked when the stream failed.
|
void |
onHeaders(Stream stream,
HeadersFrame frame)
Callback method invoked when a HEADERS frame representing the HTTP response has been received.
|
boolean |
onIdleTimeout(Session session)
Callback method invoked when the idle timeout expired.
|
boolean |
onIdleTimeout(Stream stream,
java.lang.Throwable x)
Callback method invoked when the stream exceeds its idle timeout.
|
Stream.Listener |
onNewStream(Stream stream,
HeadersFrame frame)
Callback method invoked when a new stream is being created upon
receiving a HEADERS frame representing a HTTP request.
|
java.util.Map<java.lang.Integer,java.lang.Integer> |
onPreface(Session session)
Callback method invoked:
|
Stream.Listener |
onPush(Stream stream,
PushPromiseFrame frame)
Callback method invoked when a PUSH_PROMISE frame has been received.
|
void |
onReset(Stream stream,
ResetFrame frame,
Callback callback)
Callback method invoked when a RST_STREAM frame has been received for this stream.
|
onAccept
onClose, onFailure, onPing, onReset, onSettings
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onClosed, onReset, onTimeout
onClose, onFailure, onPing, onReset, onSettings
protected HTTP2ServerConnection getConnection()
public java.util.Map<java.lang.Integer,java.lang.Integer> onPreface(Session session)
Session.Listener
Callback method invoked:
onPreface
in interface Session.Listener
onPreface
in class Session.Listener.Adapter
session
- the sessionpublic Stream.Listener onNewStream(Stream stream, HeadersFrame frame)
Session.Listener
Callback method invoked when a new stream is being created upon receiving a HEADERS frame representing a HTTP request.
Applications should implement this method to process HTTP requests,
typically providing a HTTP response via
Stream.headers(HeadersFrame, Callback)
.
Applications can detect whether request DATA frames will be arriving
by testing HeadersFrame.isEndStream()
. If the application is
interested in processing the DATA frames, it must return a
Stream.Listener
implementation that overrides
Stream.Listener.onData(Stream, DataFrame, Callback)
.
onNewStream
in interface Session.Listener
onNewStream
in class Session.Listener.Adapter
stream
- the newly created streamframe
- the HEADERS frame receivedStream.Listener
that will be notified of stream eventspublic boolean onIdleTimeout(Session session)
Session.Listener
Callback method invoked when the idle timeout expired.
onIdleTimeout
in interface Session.Listener
onIdleTimeout
in class Session.Listener.Adapter
session
- the sessionpublic void onClose(Session session, GoAwayFrame frame, Callback callback)
Session.Listener
Callback method invoked when a GOAWAY frame has been received.
onClose
in interface Session.Listener
session
- the sessionframe
- the GOAWAY frame receivedcallback
- the callback to notify of the GOAWAY processingpublic void onFailure(Session session, java.lang.Throwable failure, Callback callback)
Session.Listener
Callback method invoked when a failure has been detected for this session.
onFailure
in interface Session.Listener
session
- the sessionfailure
- the failurecallback
- the callback to notify of failure processingpublic void onHeaders(Stream stream, HeadersFrame frame)
Stream.Listener
Callback method invoked when a HEADERS frame representing the HTTP response has been received.
onHeaders
in interface Stream.Listener
stream
- the streamframe
- the HEADERS frame receivedpublic Stream.Listener onPush(Stream stream, PushPromiseFrame frame)
Stream.Listener
Callback method invoked when a PUSH_PROMISE frame has been received.
onPush
in interface Stream.Listener
stream
- the streamframe
- the PUSH_PROMISE frame receivedpublic void onData(Stream stream, DataFrame frame, Callback callback)
Stream.Listener
Callback method invoked when a DATA frame has been received.
onData
in interface Stream.Listener
stream
- the streamframe
- the DATA frame receivedcallback
- the callback to complete when the bytes of the DATA frame have been consumedpublic void onReset(Stream stream, ResetFrame frame, Callback callback)
Stream.Listener
Callback method invoked when a RST_STREAM frame has been received for this stream.
onReset
in interface Stream.Listener
stream
- the streamframe
- the RST_FRAME receivedcallback
- the callback to complete when the reset has been handledpublic void onFailure(Stream stream, int error, java.lang.String reason, Callback callback)
Stream.Listener
Callback method invoked when the stream failed.
onFailure
in interface Stream.Listener
stream
- the streamerror
- the error codereason
- the error reason, or nullcallback
- the callback to complete when the failure has been handledpublic boolean onIdleTimeout(Stream stream, java.lang.Throwable x)
Stream.Listener
Callback method invoked when the stream exceeds its idle timeout.
onIdleTimeout
in interface Stream.Listener
stream
- the streamx
- the timeout failureStream.getIdleTimeout()
Copyright © 1995–2023 Webtide. All rights reserved.