InBandBytestreamRequest.java
- /**
- *
- * Copyright the original author or authors
- *
- * Licensed 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.jivesoftware.smackx.bytestreams.ibb;
- import org.jivesoftware.smack.SmackException.NotConnectedException;
- import org.jivesoftware.smack.XMPPConnection;
- import org.jivesoftware.smack.packet.IQ;
- import org.jivesoftware.smackx.bytestreams.BytestreamRequest;
- import org.jivesoftware.smackx.bytestreams.ibb.packet.Open;
- import org.jxmpp.jid.Jid;
- /**
- * InBandBytestreamRequest class handles incoming In-Band Bytestream requests.
- *
- * @author Henning Staib
- */
- public class InBandBytestreamRequest implements BytestreamRequest {
- /* the bytestream initialization request */
- private final Open byteStreamRequest;
- /*
- * In-Band Bytestream manager containing the XMPP connection and helper
- * methods
- */
- private final InBandBytestreamManager manager;
- protected InBandBytestreamRequest(InBandBytestreamManager manager,
- Open byteStreamRequest) {
- this.manager = manager;
- this.byteStreamRequest = byteStreamRequest;
- }
- /**
- * Returns the sender of the In-Band Bytestream open request.
- *
- * @return the sender of the In-Band Bytestream open request
- */
- @Override
- public Jid getFrom() {
- return this.byteStreamRequest.getFrom();
- }
- /**
- * Returns the session ID of the In-Band Bytestream open request.
- *
- * @return the session ID of the In-Band Bytestream open request
- */
- @Override
- public String getSessionID() {
- return this.byteStreamRequest.getSessionID();
- }
- /**
- * Accepts the In-Band Bytestream open request and returns the session to
- * send/receive data.
- *
- * @return the session to send/receive data
- * @throws NotConnectedException if the XMPP connection is not connected.
- * @throws InterruptedException if the calling thread was interrupted.
- */
- @Override
- public InBandBytestreamSession accept() throws NotConnectedException, InterruptedException {
- XMPPConnection connection = this.manager.getConnection();
- // create In-Band Bytestream session and store it
- InBandBytestreamSession ibbSession = new InBandBytestreamSession(connection,
- this.byteStreamRequest, this.byteStreamRequest.getFrom());
- this.manager.getSessions().put(this.byteStreamRequest.getSessionID(), ibbSession);
- // acknowledge request
- IQ resultIQ = IQ.createResultIQ(this.byteStreamRequest);
- connection.sendStanza(resultIQ);
- return ibbSession;
- }
- /**
- * Rejects the In-Band Bytestream request by sending a reject error to the
- * initiator.
- * @throws NotConnectedException if the XMPP connection is not connected.
- * @throws InterruptedException if the calling thread was interrupted.
- */
- @Override
- public void reject() throws NotConnectedException, InterruptedException {
- this.manager.replyRejectPacket(this.byteStreamRequest);
- }
- }