}
    }
    
    private void handleRdmaWrite(Smb2WriteRequest request) throws IOException {
        // Register write data buffer for RDMA
        ByteBuffer writeBuffer = ByteBuffer.wrap(request.getData());
        RdmaMemoryRegion writeRegion = provider.registerMemory(writeBuffer,
            EnumSet.of(RdmaAccess.LOCAL_READ, RdmaAccess.REMOTE_READ));
        
        try {

        return this;
    }

    @Override
    public EventSpyDispatcher getEventSpyDispatcher() {
        return eventSpyDispatcher;
    }

    @Override
    public Map<String, Object> getData() {
        if (data == null) {
            data = new HashMap<>();
        }

        return data;
    }

            return;
        } catch (final DfsReferral dr) {
            StringBuffer redir = req.getRequestURL();
            final String qs = req.getQueryString();
            final DfsReferralData refdata = dr.getData();
            redir = new StringBuffer(redir.substring(0, redir.length() - req.getPathInfo().length()));
            redir.append('/');
            redir.append(refdata.getServer());
            redir.append('/');

      }
    }

    @Override
    public final V apply(K key) {
      return getUnchecked(key);
    }

    @Override
    public ImmutableMap<K, V> getAll(Iterable<? extends K> keys) throws ExecutionException {
      Map<K, V> map = new HashMap<K, V>();
      for (K key : keys) {
        map.put(key, localCache.getOrLoad(key));
      }

	return h, nil
}

// SendFromStore - reads the log from store and sends it to webhook.
func (h *Target) SendFromStore(key store.Key) (err error) {
	var eventData []byte
	eventData, err = h.store.GetRaw(key)
	if err != nil {
		if os.IsNotExist(err) {
			return nil
		}
		return err
	}

	count := 1
	v := strings.Split(key.Name, ":")
	if len(v) == 2 {
		count, err = strconv.Atoi(v[0])

     * @param accessResultData the access result data containing serialized data
     * @return the deserialized object
     */
    @Override
    public Object getData(final AccessResultData<?> accessResultData) {
        final byte[] data = accessResultData.getData();
        if (data != null) {
            try {
                return dataSerializer.fromBinaryToObject(data);
            } catch (final Exception e) {

        RepositorySystemSession result = newCloseableSession(request, new MavenChainedWorkspaceReader());
        MavenSession session = new MavenSession(result, request, new DefaultMavenExecutionResult());
        result.getData().set(MavenSession.class, session); // for legacy code to grab this
        session.setSession(defaultSessionFactory.newSession(session));
        return result;
    }

     */
    protected InputStream getContentStream(final DeferredFileOutputStream dfos) throws IOException {
        if (dfos.isInMemory()) {
            return new ByteArrayInputStream(dfos.getData());
        }
        return new BufferedInputStream(new FileInputStream(dfos.getFile()));
    }

    /**
     * Returns a content from a writer.
     *
     * @param out A content writer.

    @Override
    public V getUnchecked(K key) {
      return autoDelegate.getUnchecked(key);
    }

    @Override
    public ImmutableMap<K, V> getAll(Iterable<? extends K> keys) throws ExecutionException {
      return autoDelegate.getAll(keys);
    }

    @Override
    public V apply(K key) {
      return autoDelegate.apply(key);
    }

    @Override

                        mergeResponseData(dataMap, responseDataMap);
                    } else {
                        final byte[] data = resultData.getData();
                        if (data != null) {
                            try {
                                final DataSerializer dataSerializer = ComponentUtil.getComponent("dataSerializer");