Examples of org.apache.abdera.protocol.server.CollectionAdapter

Package org.apache.abdera.protocol.server

Examples of org.apache.abdera.protocol.server.CollectionAdapter

org.apache.abdera.protocol.server.CollectionAdapter
The CollectionAdapter interface is the component that provides the business logic of an Atompub server. The Provider will use it's WorkspaceManager to determine which CollectionAdapter to dispatch a request to. Once an adapter is selected, the Provider will determine what kind of request is being made and will forward the request on to the appropriate CollectionAdapter method.


  public CollectionAdapter getCollectionAdapter(RequestContext request) {
    String path = request.getTargetBasePath() + request.getTargetPath();
    
    // Typically this happens when a Resolver wants to override the CollectionAdapter being used
    CollectionAdapter ca = (CollectionAdapter) request.getAttribute(Scope.REQUEST, COLLECTION_ADAPTER_ATTRIBUTE);
    if (ca != null) {
      return ca;
    }
    for (WorkspaceInfo wi : workspaces) {
      for (CollectionInfo ci : wi.getCollections(request)) {

View Full Code Here

          method.equalsIgnoreCase("GET")) {
          return getServiceDocument(request);
      }
      WorkspaceManager wm = getWorkspaceManager(request);
      
      CollectionAdapter adapter = 
        wm.getCollectionAdapter(request);
      if (adapter == null) {
        return ProviderHelper.notfound(
          request);
      }
      
      Transactional transaction = 
        adapter instanceof Transactional ? 
          (Transactional)adapter : null;
      ResponseContext response = null;
      try {
        if (transaction != null) transaction.start(request);
        if (type == TargetType.TYPE_CATEGORIES) {
          if (method.equalsIgnoreCase("GET"))
            response = adapter.getCategories(request);
        } else if (type == TargetType.TYPE_COLLECTION) {
          if (method.equalsIgnoreCase("GET")) 
            response = adapter.getFeed(request);
          else if (method.equalsIgnoreCase("POST")) {
            response = ProviderHelper.isAtom(request) ?
              adapter.postEntry(request) :
              adapter instanceof MediaCollectionAdapter ?
                ((MediaCollectionAdapter)adapter).postMedia(request) :
                ProviderHelper.notsupported(request);
          }
        } else if (type == TargetType.TYPE_ENTRY) {
          if (method.equalsIgnoreCase("GET")) 
            response = adapter.getEntry(request);
          else if (method.equalsIgnoreCase("PUT")) 
            response = adapter.putEntry(request);
          else if (method.equalsIgnoreCase("DELETE")) 
            response = adapter.deleteEntry(request);
          else if (method.equalsIgnoreCase("HEAD")) 
            response = adapter.headEntry(request);
          else if (method.equalsIgnoreCase("OPTIONS")) 
            response = adapter.optionsEntry(request);
        } else if (type == TargetType.TYPE_MEDIA) {
          if (adapter instanceof MediaCollectionAdapter) {
            MediaCollectionAdapter mcadapter = 
              (MediaCollectionAdapter) adapter;
            if (method.equalsIgnoreCase("GET")) 
              response = mcadapter.getMedia(request);
            else if (method.equalsIgnoreCase("PUT")) 
              response = mcadapter.putMedia(request);
            else if (method.equalsIgnoreCase("DELETE")) 
              response = mcadapter.deleteMedia(request);   
            else if (method.equalsIgnoreCase("HEAD")) 
              response = mcadapter.headMedia(request);   
            else if (method.equalsIgnoreCase("OPTIONS")) 
              response = mcadapter.optionsMedia(request);        
          } else {
            response = ProviderHelper.notsupported(request);
          }
        } else if (type == TargetType.TYPE_NOT_FOUND) {
          response = ProviderHelper.notfound(request);
        } else {
          response = adapter.extensionRequest(request);
        }
        if (response == null)
          response = ProviderHelper.notsupported(request);
        return response;
      } catch (Throwable e) {

View Full Code Here

          getConfigStore().getAdapterConfiguration(getNameSpace(), config.getTargetAdapterName());
    } catch (FeedConfigStoreException e) {
      throwApplyingWrapperError(config);
    }
    getConfiguration().setAdapterConfig((NamespacedAdapterConfiguration) targetAdapterConfig);
    CollectionAdapter adapter = null;
    try {
      adapter = FeedServerAdapterManager.createWrappedAdapter(getConfiguration(), getAbdera());
    } catch (SecurityException e) {
      throwApplyingWrapperError(config);
    } catch (IllegalArgumentException e) {

View Full Code Here

    for (Constructor<?> element : ctors) {
      logger.finest("Public constructor found: " + element);
    }
    Constructor<?> c = adapterClass.getConstructor(paramClasses);
    c.setAccessible(true);
    CollectionAdapter adapterInstance = (CollectionAdapter) c.newInstance(objects);
    return adapterInstance;
  }

View Full Code Here

0 1

TOP

Related Classes of org.apache.abdera.protocol.server.CollectionAdapter

com.google.feedserver.manager.AbstractWrapperManager

com.google.feedserver.manager.FeedServerAdapterManager

com.trsst.server.AbderaProvider

org.apache.abdera.protocol.server.impl.AbstractProvider

org.apache.abdera.protocol.server.impl.DefaultWorkspaceManager

org.apache.abdera.protocol.server.impl.RouteManager

org.apache.abdera.protocol.server.provider.managed.CollectionAdapterManager

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.