CouchbaseEndpoint extends ScheduledPollEndpoint { public int getPort() { return port; } CouchbaseEndpoint();  CouchbaseEndpoint(String uri, String remaining, CouchbaseComponent component);  CouchbaseEndpoint(String endpointUri); @Override Producer createProducer(); @Override Consumer createConsumer(Processor processor); @Override boolean isSingleton(); String getProtocol(); void setProtocol(String protocol); String getBucket(); void setBucket(String bucket); String getHostname(); void setHostname(String hostname); int getPort(); void setPort(int port); String getKey(); void setKey(String key); String getUsername(); void setUsername(String username); String getPassword(); void setPassword(String password); String getAdditionalHosts(); void setAdditionalHosts(String additionalHosts); int getPersistTo(); void setPersistTo(int persistTo); int getReplicateTo(); void setReplicateTo(int replicateTo); String getOperation(); void setOperation(String operation); boolean isAutoStartIdForInserts(); void setAutoStartIdForInserts(boolean autoStartIdForInserts); long getStartingIdForInsertsFrom(); void setStartingIdForInsertsFrom(long startingIdForInsertsFrom); int getProducerRetryAttempts(); void setProducerRetryAttempts(int producerRetryAttempts); int getProducerRetryPause(); void setProducerRetryPause(int producerRetryPause); String getDesignDocumentName(); void setDesignDocumentName(String designDocumentName); String getViewName(); void setViewName(String viewName); int getLimit(); void setLimit(int limit); boolean isDescending(); void setDescending(boolean descending); int getSkip(); void setSkip(int skip); String getRangeStartKey(); void setRangeStartKey(String rangeStartKey); String getRangeEndKey(); void setRangeEndKey(String rangeEndKey); String getConsumerProcessedStrategy(); void setConsumerProcessedStrategy(String consumerProcessedStrategy); long getOpTimeOut(); void setOpTimeOut(long opTimeOut); int getTimeoutExceptionThreshold(); void setTimeoutExceptionThreshold(int timeoutExceptionThreshold); int getReadBufferSize(); void setReadBufferSize(int readBufferSize); boolean isShouldOptimize(); void setShouldOptimize(boolean shouldOptimize); long getMaxReconnectDelay(); void setMaxReconnectDelay(long maxReconnectDelay); long getOpQueueMaxBlockTime(); void setOpQueueMaxBlockTime(long opQueueMaxBlockTime); long getObsPollInterval(); void setObsPollInterval(long obsPollInterval); long getObsTimeout(); void setObsTimeout(long obsTimeout); URI[] makeBootstrapURI();  }
@Test public void testDefaultPortIsSet() throws Exception { CouchbaseEndpoint endpoint = new CouchbaseEndpoint("couchbase:http: assertEquals(DEFAULT_COUCHBASE_PORT, endpoint.getPort()); }