Adds newly created export point to the workplace configuration.<p>

@param uri the export point uri
@param destination the export point destination
425321
public void addExportPoint(String uri, String destination) {

        CmsExportPoint point = new CmsExportPoint(uri, destination);
        m_exportPoints.add(point);
        if (CmsLog.INIT.isInfoEnabled() && (point.getDestinationPath() != null)) {
            CmsLog.INIT.info(
                Messages.get().getBundle().key(
                    Messages.INIT_ADD_EXPORT_POINT_2,
                    point.getUri(),
                    point.getDestinationPath()));
        }
    }
667291
public I_CmsExportPointDriver createExportPointDriver(Set<CmsExportPoint> exportPoints) {

        if (m_tempExportpointPaths.isEmpty()) {
            return new CmsExportPointDriver(exportPoints);
        } else {
            return new CmsTempFolderExportPointDriver(exportPoints, getTempExportPointPaths());
        }

    }
210733
public File write(File destination) throws IOException {
		assertValid();
		
		if (destination.isDirectory() == true) {
			destination = new File(destination, this.header.getFileName());
		}
		if (data != null) {
			FileUtil.writeBytes(data, destination);
			data = null;
		} else {
			if (tempFile != null) {
				FileUtil.move(tempFile, destination, true);
			}
		}
		return destination;
	}
1226533
public void setExports(java.util.Collection<Export> exports) {
        if (exports == null) {
            this.exports = null;
            return;
        }

        this.exports = new com.amazonaws.internal.SdkInternalList<Export>(exports);
    }
1232423
public ScanWriter createScanWriter(int taskId, ScanDestination destination) {
        if (destination.isDiscarding()) {
            return _scanWriterFactory.createDiscardingScanWriter(taskId, Optional.<Integer>absent());
        }

        URI uri = destination.getUri();
        String scheme = uri.getScheme();

        if ("file".equals(scheme)) {
            return _scanWriterFactory.createFileScanWriter(taskId, uri, Optional.<Integer>absent());
        }

        if ("s3".equals(scheme)) {
            return _scanWriterFactory.createS3ScanWriter(taskId, uri, Optional.<Integer>absent());
        }

        throw new IllegalArgumentException("Unsupported destination: " + destination);
    }
490292
public static ExtractJobConfiguration of(TableId sourceTable, String destinationUri) {
    return newBuilder(sourceTable, destinationUri).build();
  }
853486
public void setURI( URI uri )
    {

        if ( uri == null )
        {
            setScheme( null );
            setUserInfo( null );
            setHost( null );
            setPort( UNDEFINED_PORT );
            setPath( null );
            setQuery( null );
            setFragment( null );
        }
        else if ( uri.isOpaque() )
        {
            setUserInfo( null );
            setHost( null );
            setPort( UNDEFINED_PORT );
            setPath( null );
            setQuery( null );
            setOpaque( uri.getScheme(), uri.getSchemeSpecificPart() );
            setFragment( uri.getRawFragment() );
        }
        else
        {
            setSchemeSpecificPart( null );
            setScheme( uri.getScheme() );
            setUserInfo( uri.getRawUserInfo() );
            setHost( uri.getHost() );
            setPort( uri.getPort() );
            setPath( uri.getRawPath() );
            setQuery( uri.getRawQuery() );
            setFragment( uri.getRawFragment() );
        }
    }
382544
public static DestinationRef asRef( Destination destination ) throws JMSException
    {
        if (destination == null)
            return null;
            
        if (destination instanceof DestinationRef)
            return (DestinationRef)destination;
        
        if (destination instanceof Queue)
            return new QueueRef(((Queue)destination).getQueueName());
        
        if (destination instanceof Topic)
            return new TopicRef(((Topic)destination).getTopicName());
        
        throw new InvalidDestinationException("Unsupported destination type : "+destination,"INVALID_DESTINATION");
    }
695091
@Override
	public MessageProducer createProducer(Destination destination) throws JMSException
    {
    	externalAccessLock.readLock().lock();
    	try
		{
	        checkNotClosed();
	        LocalMessageProducer producer = new LocalMessageProducer(this,destination,idProvider.createID());
	        registerProducer(producer);
	        return producer;
		}
    	finally
    	{
    		externalAccessLock.readLock().unlock();
    	}
    }
163275
protected void writeResource(String resourceName, String exportpoint, byte[] content) {

        File file = getExportPointFile(resourceName, exportpoint);
        writeResource(file, content);
    }
1073159
protected void handleImportStyle(final String uri, final MediaQueryList media,
            final String defaultNamespaceURI, final Locator locator) {
        getDocumentHandler().importStyle(uri, media, defaultNamespaceURI, locator);
    }
11024
public Bus<M> addDestination(Destination<M> destination) {
		if(destination != null) {
			logger.info("adding destination '{}' of class '{}'", destination.getId(), destination.getClass().getSimpleName());
			destinations.add(destination);
		}
		return this;
	}
1185719
protected void addPubSubLocalisation(
                                         LocalizationDefinition destinationLocalizationDefinition)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "addPubSubLocalisation",
                        new Object[] {
                        destinationLocalizationDefinition });

        _pubSubRealization.addPubSubLocalisation(destinationLocalizationDefinition);

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "addPubSubLocalisation");

    }
310367
public static DestinationUrl createDestinationUrl(String destination) {
        String[] split = splitDestination(destination);
        String host = split[0].trim();
        String jmsDestination = split[1].trim();
        return new DestinationUrl(host, jmsDestination);
    }
813148
public static void copyResource(String resource, File destination) throws IOException {
        InputStream is = null;
        FileOutputStream fos = null;

        try {
            is = FileUtils.class.getResourceAsStream("/" + resource);
            fos = new FileOutputStream(destination);

            final byte[] buffer = new byte[10 * 1024];
            int len;
            while ((len = is.read(buffer)) > 0) {
                fos.write(buffer, 0, len);
            }
        } finally {
            close(is);
            close(fos);
        }

    }
628251
protected void moveResource(CmsDbContext dbc, CmsResource source, String destination) throws CmsException {

        List<CmsResource> resources = null;

        if (source.isFolder()) {
            if (!CmsResource.isFolder(destination)) {
                // ensure folder name end's with a /
                destination = destination.concat("/");
            }
            // collect all resources in the folder without checking permissions
            resources = m_driverManager.readChildResources(dbc, source, CmsResourceFilter.ALL, true, true, false);
        }

        // target permissions will be checked later
        m_driverManager.moveResource(dbc, source, destination, false);

        // make sure lock is set
        CmsResource destinationResource = m_driverManager.readResource(dbc, destination, CmsResourceFilter.ALL);
        try {
            // the destination must always get a new lock
            m_driverManager.lockResource(dbc, destinationResource, CmsLockType.EXCLUSIVE);
        } catch (Exception e) {
            // could happen with with shared locks on single files
            if (LOG.isWarnEnabled()) {
                LOG.warn(e);
            }
        }

        if (resources != null) {
            // now walk through all sub-resources in the folder
            for (int i = 0; i < resources.size(); i++) {
                CmsResource childResource = resources.get(i);
                String childDestination = destination.concat(childResource.getName());
                // recurse with child resource
                moveResource(dbc, childResource, childDestination);
            }
        }
        CmsProject currentProject = dbc.getRequestContext().getCurrentProject();
        if (!currentProject.isOnlineProject()) {
            List<CmsResource> movedResources = m_driverManager.readChildResources(
                dbc,
                destinationResource,
                CmsResourceFilter.ALL,
                true,
                true,
                false);
            movedResources.add(destinationResource);
            for (CmsResource res : movedResources) {
                m_driverManager.repairCategories(dbc, dbc.getRequestContext().getCurrentProject().getUuid(), res);
            }
        }
    }
1050648
public AsyncMessage createMessageForDestination(String destination) {
        AsyncMessage message = this.defaultMessageCreator.createMessage();
        message.setDestination(destination);
        return message;
    }