com.liferay.portal.dao.shard
Class ShardAdvice

java.lang.Object
  extended by com.liferay.portal.dao.shard.ShardAdvice

public class ShardAdvice
extends java.lang.Object

View Source

Author:
Michael Young, Alexander Chow

Constructor Summary
ShardAdvice()
           
 
Method Summary
 void afterPropertiesSet()
           
protected  java.lang.String getCurrentShardName()
           
protected  javax.sql.DataSource getDataSource()
           
 java.lang.Object invokeByParameter(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
           
 java.lang.Object invokeCompanyService(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
           
 java.lang.Object invokeGlobally(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
          Invoke a join point across all shards while ignoring the company service stack.
 java.lang.Object invokeIteratively(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
          Invoke a join point across all shards while using the company service stack.
 java.lang.Object invokePersistence(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
           
 java.lang.Object invokePortletService(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
           
protected  java.lang.String popCompanyService()
           
protected  void pushCompanyService(long companyId)
           
protected  void pushCompanyService(java.lang.String shardName)
           
 void setShardDataSourceTargetSource(ShardDataSourceTargetSource shardDataSourceTargetSource)
           
 void setShardSessionFactoryTargetSource(ShardSessionFactoryTargetSource shardSessionFactoryTargetSource)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ShardAdvice

public ShardAdvice()
Method Detail

afterPropertiesSet

public void afterPropertiesSet()

invokeByParameter

public java.lang.Object invokeByParameter(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
                                   throws java.lang.Throwable
Throws:
java.lang.Throwable

invokeCompanyService

public java.lang.Object invokeCompanyService(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
                                      throws java.lang.Throwable
Throws:
java.lang.Throwable

invokeGlobally

public java.lang.Object invokeGlobally(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
                                throws java.lang.Throwable
Invoke a join point across all shards while ignoring the company service stack.

Throws:
java.lang.Throwable
See Also:
invokeIteratively(org.aspectj.lang.ProceedingJoinPoint)

invokeIteratively

public java.lang.Object invokeIteratively(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
                                   throws java.lang.Throwable
Invoke a join point across all shards while using the company service stack.

Throws:
java.lang.Throwable
See Also:
invokeGlobally(org.aspectj.lang.ProceedingJoinPoint)

invokePersistence

public java.lang.Object invokePersistence(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
                                   throws java.lang.Throwable
Throws:
java.lang.Throwable

invokePortletService

public java.lang.Object invokePortletService(org.aspectj.lang.ProceedingJoinPoint proceedingJoinPoint)
                                      throws java.lang.Throwable
Throws:
java.lang.Throwable

setShardDataSourceTargetSource

public void setShardDataSourceTargetSource(ShardDataSourceTargetSource shardDataSourceTargetSource)

setShardSessionFactoryTargetSource

public void setShardSessionFactoryTargetSource(ShardSessionFactoryTargetSource shardSessionFactoryTargetSource)

getCurrentShardName

protected java.lang.String getCurrentShardName()

getDataSource

protected javax.sql.DataSource getDataSource()

popCompanyService

protected java.lang.String popCompanyService()

pushCompanyService

protected void pushCompanyService(long companyId)

pushCompanyService

protected void pushCompanyService(java.lang.String shardName)